Package co.paralleluniverse.strands.channels

Class TimeoutChannel<Message>

java.lang.Object

co.paralleluniverse.strands.channels.TransferChannel<Message>

co.paralleluniverse.strands.channels.TimeoutChannel<Message>

All Implemented Interfaces:

Channel<Message>, Port<Message>, PortAutoCloseable, ReceivePort<Message>, Selectable<Message>, SendPort<Message>, StandardChannel<Message>, Synchronization, java.lang.AutoCloseable

public class TimeoutChannel<Message>
extends TransferChannel<Message>

Nested Class Summary

Nested classes/interfaces inherited from interface co.paralleluniverse.strands.channels.ReceivePort

ReceivePort.EOFException

Method Summary

Modifier and Type	Method	Description
static <Message> Channel<Message>	timeout(long timeout, java.util.concurrent.TimeUnit unit)

Methods inherited from class co.paralleluniverse.strands.channels.TransferChannel

capacity, close, close, equals, getWaitingConsumerCount, isClosed, isSingleConsumer, isSingleProducer, receive, receive, receive, receiveInternal, register, register, send, send, send, tryNow, tryReceive, trySend, unregister

Methods inherited from class java.lang.Object

clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

timeout

public static <Message> Channel<Message> timeout(long timeout,
                                                 java.util.concurrent.TimeUnit unit)