lib/polyphony/core/channel.rb in polyphony-0.99 vs lib/polyphony/core/channel.rb in polyphony-0.99.1

@@ -6,9 +6,11 @@
   # Implements a unidirectional communication channel along the lines of Go
   # (buffered) channels.
   class Channel < Polyphony::Queue
     alias_method :receive, :shift
 
+    # Closes the channel, resuming any fibers waiting on the channel with
+    # a Polyphony::MoveOn exception
     def close
       flush_waiters(Polyphony::MoveOn.new)
     end
   end
 end