Contents

# encoding: utf-8

ctx = ZMQ::Context.new
pull = ctx.socket(:PULL)
pull.connect($runner.endpoint)

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

$runner.stats(start_time)

Version data entries

28 entries across 28 versions & 1 rubygems

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