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