lib/agent/selector.rb in agent-0.9.1 vs lib/agent/selector.rb in agent-0.10.0

@@ -101,10 +101,10 @@
       @operations[chan] = []
       cse
     end
 
     def execute_case(operation)
-      raise Errors::ChannelClosed if operation.closed?
+      raise Errors::ChannelClosed if operation.closed? && operation.is_a?(Agent::Push)
 
       cse = @cases[operation.uuid]
       blk, direction = cse.blk, cse.direction
 
       if blk