Class: Rewire::Pipe

Inherits:

Object

• Object
• Rewire::Pipe

Defined in:

lib/rewire/pipe.rb

Instance Method Summary

• #<<(pack) ⇒ Object
• #initialize(&logic) ⇒ Pipe constructor

  A new instance of Pipe.

• #process(receiver, pack) ⇒ Object
• #|(pipe) ⇒ Object

Constructor Details

#initialize(&logic) ⇒ Pipe

Returns a new instance of Pipe.

# File 'lib/rewire/pipe.rb', line 3

def initialize(&logic)
  @logic = logic
end

Instance Method Details

#<<(pack) ⇒ Object

# File 'lib/rewire/pipe.rb', line 11

def <<(pack)
  output = []
  (self | output) << pack
  output
end

#process(receiver, pack) ⇒ Object

# File 'lib/rewire/pipe.rb', line 17

def process(receiver, pack)
  @logic[receiver, pack]
end

#|(pipe) ⇒ Object

# File 'lib/rewire/pipe.rb', line 7

def |(pipe)
  Emitter.new(self) | pipe
end