lib/agent/channel.rb in agent-0.10.0 vs lib/agent/channel.rb in agent-0.11.0

@@ -59,11 +59,13 @@
     # Receiving methods
 
     def receive(options={})
       check_direction(:receive)
       q = queue
-      return [nil, false] unless q
-      q.pop(options)
+      return q.pop(options) if q
+      pop = Pop.new(options)
+      pop.close
+      [pop.object, false]
     end
     alias :pop  :receive
 
     def pop?; queue.pop?; end
     alias :receive? :pop?