Sha256: 080c4b885263bf43eccd22179242b8a1f8a70fd557aba64e6e593749cbf9f63e
Contents?: true
Size: 240 Bytes
Versions: 2
Compression:
Stored size: 240 Bytes
Contents
class Datapipes # Build your own sink logic in `run` method. class Sink include Composable # TODO: parallel def run_all(data) @accumulated ||= [self] @accumulated.each {|sink| sink.run(data) } end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
datapipes-0.1.1 | lib/datapipes/sink.rb |
datapipes-0.1.0 | lib/datapipes/sink.rb |