Contents

#!/usr/bin/env ruby

require 'zmachine/zmq_channel'

include ZMachine

server = ZMQChannel.new(ZMQ::REP)
#server.bind("tcp://0.0.0.0:12345")
server.bind("inproc://x")

client = ZMQChannel.new(ZMQ::REQ)
#client.connect("tcp://0.0.0.0:12345")
client.connect("inproc://x")

data = ("x" * 2048).to_java_bytes

loop do
  client.send_data([data])
  received = server.read_inbound_data.first
  puts received
  server.send_data([data])
  client.read_inbound_data
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
zmachine-0.4.3	benchmarks/zmq_channel.rb
zmachine-0.4.2	benchmarks/zmq_channel.rb
zmachine-0.4.1	benchmarks/zmq_channel.rb
zmachine-0.4.0	benchmarks/zmq_channel.rb
zmachine-0.3.2	benchmarks/zmq_channel.rb
zmachine-0.3.0	benchmarks/zmq_channel.rb
zmachine-0.2.1	benchmarks/zmq_channel.rb
zmachine-0.2.0	benchmarks/zmq_channel.rb