Package | Description |
---|---|
org.xnio |
The main API package for XNIO.
|
Modifier and Type | Method and Description |
---|---|
static ChannelExceptionHandler<Channel> |
ChannelListeners.closingChannelExceptionHandler()
Get a channel exception handler which closes the channel upon exception.
|
Modifier and Type | Method and Description |
---|---|
static <T extends StreamSourceChannel> |
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> |
ChannelListeners.fileReceivingChannelListener(FileChannel target,
long position,
long count,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A file-receiving channel listener.
|
static <T extends StreamSinkChannel> |
ChannelListeners.fileSendingChannelListener(FileChannel source,
long position,
long count,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A file-sending channel listener.
|
static <T extends SuspendableWriteChannel> |
ChannelListeners.flushingChannelListener(ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A flushing channel listener.
|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
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<ByteBuffer> pool)
Initiate a low-copy transfer between two stream channels.
|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
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<ByteBuffer> pool)
Initiate a low-copy transfer between two stream channels.
|
static <T extends Channel> |
ChannelListeners.invokeChannelExceptionHandler(T channel,
ChannelExceptionHandler<? super T> exceptionHandler,
IOException exception)
Safely invoke a channel exception handler, logging any errors.
|
static <T extends WritableMessageChannel> |
ChannelListeners.sendingChannelListener(Pooled<ByteBuffer> pooled,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A sending channel listener.
|
static <T extends SuspendableWriteChannel> |
ChannelListeners.writeShutdownChannelListener(ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A write shutdown channel listener.
|
static <T extends StreamSinkChannel> |
ChannelListeners.writingChannelListener(Pooled<ByteBuffer> pooled,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A writing channel listener.
|
Copyright © 2015. All rights reserved.