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