Contents

# A sink is never called concurrently.
# On the other side, each sink can be called concurrently.
# So be careful to occur race condition in multi sinks.
class Acc < Datapipes::Sink
  attr_reader :stock

  def initialize
    @stock = []
  end

  def run(data)
    @stock << data
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

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