Contents

# encoding: utf-8

ctx = ZMQ::Context.new
pair = ctx.socket(:PAIR)
sleep 2
pair.connect($runner.endpoint)

messages, start_time = 0, nil
while (case $runner.encoding
  when :string
    pair.recv
  when :frame
    pair.recv_frame
  when :message
    pair.recv_message
  end) do
  start_time ||= Time.now
  messages += 1
  break if messages == $runner.msg_count
end

$runner.stats(start_time)

Version data entries

28 entries across 28 versions & 1 rubygems

Version	Path
rbczmq-1.7.9	perf/pair/local.rb
rbczmq-1.7.8	perf/pair/local.rb
rbczmq-1.7.7	perf/pair/local.rb
rbczmq-1.7.6	perf/pair/local.rb
rbczmq-1.7.5	perf/pair/local.rb
rbczmq-1.7.4	perf/pair/local.rb
rbczmq-1.7.3	perf/pair/local.rb
rbczmq-1.7.2	perf/pair/local.rb
rbczmq-1.7.1	perf/pair/local.rb
rbczmq-1.7.0	perf/pair/local.rb
rbczmq-1.6.4	perf/pair/local.rb
rbczmq-1.6.2	perf/pair/local.rb
rbczmq-1.6	perf/pair/local.rb
rbczmq-1.5	perf/pair/local.rb
rbczmq-1.4	perf/pair/local.rb
rbczmq-1.3	perf/pair/local.rb
rbczmq-1.2	perf/pair/local.rb
rbczmq-1.1	perf/pair/local.rb
rbczmq-1.0	perf/pair/local.rb
rbczmq-0.9	perf/pair/local.rb