lib/ffi-rzmq/socket.rb in ffi-rzmq-0.9.7 vs lib/ffi-rzmq/socket.rb in ffi-rzmq-1.0.0
- old
+ new
@@ -432,11 +432,11 @@
def send_multiple(parts, flags, method_name)
if !parts || parts.empty?
-1
else
flags = NonBlocking if dontwait?(flags)
- rc = nil
+ rc = 0
parts[0..-2].each do |part|
rc = send(method_name, part, (flags | ZMQ::SNDMORE))
break unless Util.resultcode_ok?(rc)
end
@@ -635,10 +635,12 @@
def remove_finalizer
ObjectSpace.undefine_finalizer self
end
def self.close socket
- Proc.new { LibZMQ.zmq_close socket }
+ Proc.new do
+ LibZMQ.zmq_close(socket) if socket && !socket.null?
+ end
end
end # class Socket for version2
end # LibZMQ.version2?