Contents

project_lib_path = File.expand_path(File.join(File.dirname(__FILE__), "..", "lib"))
$LOAD_PATH.unshift(project_lib_path)
require 'agent'

c = channel!(Integer)

go!(c) do |c|
  i = 0
  loop { c << i+= 1 }
end

p c.receive[0] # => 1
p c.receive[0] # => 2

c.close

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
agent-0.12.0	examples/producer-consumer.rb
agent-0.11.0	examples/producer-consumer.rb
agent-0.10.0	examples/producer-consumer.rb
agent-0.9.1	examples/producer-consumer.rb
agent-0.9.0	examples/producer-consumer.rb