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?