DisconnectAwareConnectionDecorator(Connection<T> connection,
StoppableExecutor executor) |
DisconnectAwareConnectionDecorator(Connection<T> connection,
StoppableExecutor executor,
int bufferSize) |
EagerReceiveBuffer(StoppableExecutor executor,
java.util.Collection<Receive<T>> receivers) |
EagerReceiveBuffer(StoppableExecutor executor,
java.util.Collection<Receive<T>> receivers,
java.lang.Runnable onReceiversExhausted) |
EagerReceiveBuffer(StoppableExecutor executor,
int bufferSize,
java.util.Collection<Receive<T>> receivers) |
EagerReceiveBuffer(StoppableExecutor executor,
int bufferSize,
java.util.Collection<Receive<T>> receivers,
java.lang.Runnable onReceiversExhausted) |
EagerReceiveBuffer(StoppableExecutor executor,
int bufferSize,
Receive<T> receiver) |
EagerReceiveBuffer(StoppableExecutor executor,
int bufferSize,
Receive<T> receiver,
java.lang.Runnable onReceiversExhausted) |
EagerReceiveBuffer(StoppableExecutor executor,
Receive<T> receiver) |
EagerReceiveBuffer(StoppableExecutor executor,
Receive<T> receiver,
java.lang.Runnable onReceiversExhausted) |