Sha256: 821c745df020bb25a73611bd8b223741dd1e88a77884cb9bccc12c30e5c0d26b
Contents?: true
Size: 394 Bytes
Versions: 28
Compression:
Stored size: 394 Bytes
Contents
# encoding: utf-8
ctx = ZMQ::Context.new
sub = ctx.socket(:SUB)
sub.subscribe("")
sub.connect($runner.endpoint)
messages, start_time = 0, nil
while (case $runner.encoding
when :string
sub.recv
when :frame
sub.recv_frame
when :message
sub.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