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