Class: Wick::Bus

Inherits:

Stream

• Object
• Stream
• Wick::Bus

Defined in:

lib/wick/bus.rb

Instance Method Summary

• #consume!(stream) ⇒ Object

Methods inherited from Stream

#<<, #at_start, #combine, #compact, #each, #flat_map, #initialize, #log!, #map, #merge, #pipe!, #sampling, #scan, #select, #start!

Constructor Details

This class inherits a constructor from Wick::Stream

Instance Method Details

#consume!(stream) ⇒ Object

# File 'lib/wick/bus.rb', line 3

def consume!(stream)
  stream.pipe!(self)
end