examples/v3api/local_lat_poll.rb in ffi-rzmq-0.9.3 vs examples/v3api/local_lat_poll.rb in ffi-rzmq-0.9.6

- old
+ new

@@ -36,22 +36,22 @@ start_time = Time.now # kick it off message = ZMQ::Message.new("a" * message_size) -assert(s1.sendmsg(message, ZMQ::DONTWAIT)) +assert(s1.sendmsg(message, ZMQ::NonBlocking)) i = roundtrip_count until i.zero? i -= 1 assert(poller.poll_nonblock) poller.readables.each do |socket| received_message = '' - assert(socket.recv_string(received_message, ZMQ::DONTWAIT)) - assert(socket.sendmsg(ZMQ::Message.new(received_message), ZMQ::DONTWAIT)) + assert(socket.recv_string(received_message, ZMQ::NonBlocking)) + assert(socket.sendmsg(ZMQ::Message.new(received_message), ZMQ::NonBlocking)) end end elapsed_usecs = (Time.now.to_f - start_time.to_f) * 1_000_000 latency = elapsed_usecs / roundtrip_count / 2