static <T extends StreamSourceChannel> ChannelListener<T> |
ChannelListeners.drainListener(long bytes,
ChannelListener<? super T> finishListener,
ChannelExceptionHandler<? super T> exceptionHandler) |
Create a channel listener which automatically drains the given number of bytes from the channel and then calls
a listener.
|
static <T extends StreamSourceChannel> ChannelListener<T> |
ChannelListeners.fileReceivingChannelListener(java.nio.channels.FileChannel target,
long position,
long count,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler) |
A file-receiving channel listener.
|
static <T extends StreamSinkChannel> ChannelListener<T> |
ChannelListeners.fileSendingChannelListener(java.nio.channels.FileChannel source,
long position,
long count,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler) |
A file-sending channel listener.
|
static <T extends SuspendableWriteChannel> ChannelListener<T> |
ChannelListeners.flushingChannelListener(ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler) |
A flushing channel listener.
|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> void |
ChannelListeners.initiateTransfer(long count,
I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
Pool<java.nio.ByteBuffer> pool) |
Initiate a low-copy transfer between two stream channels.
|
static <T extends java.nio.channels.Channel> void |
ChannelListeners.invokeChannelExceptionHandler(T channel,
ChannelExceptionHandler<? super T> exceptionHandler,
java.io.IOException exception) |
Safely invoke a channel exception handler, logging any errors.
|
static <T extends WritableMessageChannel> ChannelListener<T> |
ChannelListeners.sendingChannelListener(Pooled<java.nio.ByteBuffer> pooled,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler) |
A sending channel listener.
|
static <T extends SuspendableWriteChannel> ChannelListener<T> |
ChannelListeners.writeShutdownChannelListener(ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler) |
A write shutdown channel listener.
|
static <T extends StreamSinkChannel> ChannelListener<T> |
ChannelListeners.writingChannelListener(Pooled<java.nio.ByteBuffer> pooled,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler) |
A writing channel listener.
|