Class: Datapipes::Sink

Inherits:

Object

• Object
• Datapipes::Sink

Includes:

Composable

Defined in:

lib/datapipes/sink.rb

Overview

Build your own sink logic in ‘run` method.

Instance Attribute Summary

Attributes included from Composable

#accumulated

Instance Method Summary

• #run_all(data) ⇒ Object

  TODO: parallel.

Methods included from Composable

#+

Instance Method Details

#run_all(data) ⇒ Object

TODO: parallel

# File 'lib/datapipes/sink.rb', line 7

def run_all(data)
  @accumulated ||= [self]
  @accumulated.each {|sink| sink.run(data) }
end