public class ChannelClosedException
extends IllegalStateException

Thrown when an AsyncChannel operation is attempted after the channel has been closed.

This exception is raised in the following situations:

• AsyncChannel.send — the channel was closed before or during the send attempt. Pending senders that were waiting for buffer space when the channel closed also receive this exception.
• AsyncChannel.receive — the channel was closed and all buffered values have been drained. Note that values buffered before closure are still delivered normally; only once the buffer is exhausted does this exception appear.

When used with for await, the loop infrastructure translates ChannelClosedException into a clean end-of-stream signal (i.e., the loop exits normally rather than propagating the exception):

 def ch = AsyncChannel.create()
 // ... producer sends values, then calls ch.close()
 for await (item in ch) {
     process(item)       // processes all buffered values
 }
 // loop exits cleanly after the channel is closed and drained
 

See Also:

AsyncChannel.send

AsyncChannel.receive

AsyncChannel.close

Since:

6.0.0