Contents

# Sink consumes piped data. A typical sink is printing data.
#
class Print < Datapipes::Sink
  def run(data)
    puts data if accept? data
  end

  def accept?(data)
    data.is_a? Array and data[0] < 7
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
datapipes-0.1.5	examples/lib/print.rb
datapipes-0.1.4	examples/lib/print.rb
datapipes-0.1.3	examples/lib/print.rb