class Rewire::Pipe

Public Class Methods

new(&logic) click to toggle source
# File lib/rewire/pipe.rb, line 3
def initialize(&logic)
  @logic = logic
end

Public Instance Methods

<<(pack) click to toggle source
# File lib/rewire/pipe.rb, line 11
def <<(pack)
  output = []
  (self | output) << pack
  output
end
process(receiver, pack) click to toggle source
# File lib/rewire/pipe.rb, line 17
def process(receiver, pack)
  @logic[receiver, pack]
end
|(pipe) click to toggle source
# File lib/rewire/pipe.rb, line 7
def |(pipe)
  Emitter.new(self) | pipe
end