Sha256: 578b1cc52d532eacd18b674ff88f646790161fb734636f5344c552d0b5570e9d
Contents?: true
Size: 479 Bytes
Versions: 3
Compression:
Stored size: 479 Bytes
Contents
require 'rzmq-enhancement' require 'pp' require 'thread' include ZeroMQ EP = 'ipc://pushpull.ipc' thr = [] # push thr << Thread.new { (0..10).each do |i| zeromq_push :push_example, EP do |ctx| unless i == 10 [i, 'mississippi'] else :end_of_stream end end end } # pull thr << Thread.new { zeromq_pull_server :pull_example, EP do |payload| pp payload exit if payload == 'end_of_stream' end } thr.each { |t| t.join }
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
rzmq-enhancement-0.0.19 | examples/push-pull.rb |
rzmq-enhancement-0.0.18 | examples/push-pull.rb |
rzmq-enhancement-0.0.14 | examples/push-pull.rb |