lib/async/channel.rb in grumlin-0.6.2 vs lib/async/channel.rb in grumlin-0.7.0
- old
+ new
@@ -30,10 +30,10 @@
@queue << [:exception, exception]
end
def close
- raise(ChannelClosedError, "Cannot close a closed channel") if closed?
+ return if closed?
@queue << [:close]
@closed = true
end