Class: Pipe::Receiver

Inherits:

EM::Connection

• Object
• EM::Connection
• Pipe::Receiver

Defined in:

lib/em-pipe-run.rb

Instance Method Summary

• #initialize(callback = nil) ⇒ Receiver constructor

  Constructor.

• #receive_data(data) ⇒ Object

  Receives data from pipe.

• #unbind ⇒ Object

  Action after terminating the connection.

Constructor Details

#initialize(callback = nil) ⇒ Receiver

Constructor.

Parameters:

• callback (Proc) (defaults to: nil) —

  callback for giving back the results

# File 'lib/em-pipe-run.rb', line 38

def initialize(callback = nil)
    @callback = callback
    @buffer = ""
end

Instance Method Details

#receive_data(data) ⇒ Object

Receives data from pipe.

Parameters:

• data (String) —

  output from pipe

# File 'lib/em-pipe-run.rb', line 48

def receive_data(data)
    @buffer << data
end

#unbind ⇒ Object

Action after terminating the connection. Calls callback.

# File 'lib/em-pipe-run.rb', line 56

def unbind
    if not @callback.nil?
        @callback.call(@buffer)
    end
end