Sha256: c83f4488893f1a2f93b180333d479d892fccded9428ba51002fc176c3c3dc1e3
Contents?: true
Size: 564 Bytes
Versions: 3
Compression:
Stored size: 564 Bytes
Contents
require 'datapipes' class List < Datapipes::Source def run (1..10).each {|i| produce(i) } end end class Triple < Datapipes::Tube def run(data) [data, data, data] end def accept?(data) data.is_a? Integer and data > 3 end end class Print < Datapipes::Sink def run(data) puts data end def accept?(data) data.is_a? Array and data[0] < 7 end end datapipe = Datapipes.new( List.new, # A source Triple.new, # A tube Print.new, # A sink Datapipes::Pipe.new # A pipe ) datapipe.run_resource
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
datapipes-0.1.0 | examples/basics.rb |
datapipes-0.0.4 | examples/basics.rb |
datapipes-0.0.3 | examples/basics.rb |