Method: Polyphony::Channel#close

Defined in:
lib/polyphony/core/channel.rb

#close ⇒ Object

Closes the channel, resuming any fibers waiting on the channel with a Polyphony::MoveOn exception



13
14
15
 
# File 'lib/polyphony/core/channel.rb', line 13

def close
  flush_waiters(Polyphony::MoveOn.new)
end