Package | Description |
---|---|
io.undertow.protocols.http2 | |
io.undertow.server.protocol.framed | |
io.undertow.util | |
io.undertow.websockets.core | |
org.xnio |
The main API package for XNIO.
|
Modifier and Type | Method and Description |
---|---|
void |
Http2Channel.sendGoAway(int status,
ChannelExceptionHandler<AbstractHttp2StreamSinkChannel> exceptionHandler) |
void |
Http2Channel.sendPing(byte[] data,
ChannelExceptionHandler<AbstractHttp2StreamSinkChannel> exceptionHandler) |
Modifier and Type | Method and Description |
---|---|
protected ChannelExceptionHandler<SuspendableWriteChannel> |
AbstractFramedChannel.writeExceptionHandler() |
Modifier and Type | Class and Description |
---|---|
class |
ClosingChannelExceptionHandler<T extends Channel>
Channel exception handler that closes the channel, logs a debug level
message and closes arbitrary other resources.
|
Modifier and Type | Method and Description |
---|---|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
Transfer.initiateTransfer(I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
ByteBufferPool pool)
Initiate a low-copy transfer between two stream channels.
|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
Transfer.initiateTransfer(I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
ByteBufferPool pool)
Initiate a low-copy transfer between two stream channels.
|
Modifier and Type | Method and Description |
---|---|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
WebSocketUtils.initiateTransfer(I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
ByteBufferPool pool)
Deprecated.
|
static <I extends StreamSourceChannel,O extends StreamSinkChannel> |
WebSocketUtils.initiateTransfer(I source,
O sink,
ChannelListener<? super I> sourceListener,
ChannelListener<? super O> sinkListener,
ChannelExceptionHandler<? super I> readExceptionHandler,
ChannelExceptionHandler<? super O> writeExceptionHandler,
ByteBufferPool pool)
Deprecated.
|
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 © 2017 JBoss by Red Hat. All rights reserved.