lib/celluloid/zmq/waker.rb in celluloid-zmq-0.0.3 vs lib/celluloid/zmq/waker.rb in celluloid-zmq-0.0.4

- old
+ new

@@ -34,14 +34,14 @@ end # Wait for another thread to signal this Waker def wait message = '' - rc = @receiver.recv_string message + rc = @receiver.recv_string message - unless ::ZMQ::Util.resultcode_ok? rc and message == PAYLOAD - raise DeadWakerError, "error receiving ZMQ string: #{::ZMQ::Util.error_string}" - end + unless ::ZMQ::Util.resultcode_ok? rc and message == PAYLOAD + raise DeadWakerError, "error receiving ZMQ string: #{::ZMQ::Util.error_string}" + end end # Clean up the IO objects associated with this waker def cleanup @sender_lock.synchronize { @sender.close rescue nil }