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 }