co.paralleluniverse.strands.channels

Interface PortAutoCloseable

All Superinterfaces:

java.lang.AutoCloseable

All Known Subinterfaces:

Channel<Message>, DoubleChannel, DoubleReceivePort, DoubleSendPort, FloatChannel, FloatReceivePort, FloatSendPort, IntChannel, IntReceivePort, IntSendPort, LongChannel, LongReceivePort, LongSendPort, Mix<M>, ReceivePort<Message>, SendPort<Message>, StandardChannel<Message>

All Known Implementing Classes:

DelegatingReceivePort, DelegatingSendPort, FlatMappingReceivePort, QueueChannel, QueueDoubleChannel, QueueFloatChannel, QueueIntChannel, QueueLongChannel, QueueObjectChannel, QueuePrimitiveChannel, ReceivePortGroup, SingleConsumerQueueChannel, SplitSendPort, TickerChannelConsumer, TickerChannelConsumer.TickerChannelFloatConsumer, TimeoutChannel, TransferChannel, TransformingReceivePort, TransformingSendPort, ValChannel, ZippingReceivePort

public interface PortAutoCloseable
extends java.lang.AutoCloseable

Method Summary

Modifier and Type	Method and Description
default void	close() Closes the channel so that no more messages could be sent to it.
default boolean	isClosed() Tests whether the channel has been closed and no more messages await in the channel.

Method Detail

close

default void close()

Closes the channel so that no more messages could be sent to it. Messages already sent to the channel will still be received.

Specified by:

close in interface java.lang.AutoCloseable

isClosed

default boolean isClosed()

Tests whether the channel has been closed and no more messages await in the channel. If this method returns true all future calls to receive are guaranteed to return null, and calls to receive on a primitive channel will throw a EOFException.

Returns:

true if the channels has been closed and no more messages will be received; false otherwise.