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