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