Method: Fall::StreamOperation#chain

Defined in:
lib/fall/stream_operation.rb

#chain(operation) ⇒ Object 



33
34
35
36
37
38
 
# File 'lib/fall/stream_operation.rb', line 33

def chain(operation)
  identity = ->(i) { i }

  composed = (func >> (operation.func >> identity))
  self.class.new(composed)
end