module IOP::Sink
Module to be included into classes which receive and process the upstream data.
@since 0.1
Attributes
upstream[RW]
Returns the upstream object or nil
if self
is the first object in processing pipe.
Public Instance Methods
process(data = nil)
click to toggle source
@abstract
@note this method should be implemented in concrete classes including this module.
Refer to {Feed#process} for more information.
# File lib/iop.rb, line 183 def process(data = nil) raise end
process!()
click to toggle source
Commences the data processing operation.
This implementation calls {#process!} method of the upstream object.
# File lib/iop.rb, line 174 def process! upstream.process! end