Sha256: 5877a78c888fb6d0f2cc501b358b02b562978f3f20fbb4a0a00c9eecd2bed4a1
Contents?: true
Size: 709 Bytes
Versions: 28
Compression:
Stored size: 709 Bytes
Contents
# encoding: utf-8
ctx = ZMQ::Context.new
req = ctx.socket(:REQ)
req.connect($runner.endpoint)
msg = $runner.payload
messages, start_time = 0, nil
while (case $runner.encoding
when :string
req.send(msg)
when :frame
req.send_frame(ZMQ::Frame(msg))
when :message
m = ZMQ::Message.new
m.pushstr "header"
m.pushstr msg
m.pushstr "body"
req.send_message(m)
end) do
start_time ||= Time.now
messages += 1
case $runner.encoding
when :string
req.recv
when :frame
req.recv_frame
when :message
req.recv_message
end
break if messages == $runner.msg_count
end
$runner.stats(start_time)
Version data entries
28 entries across 28 versions & 1 rubygems