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