Package | Description |
---|---|
io.undertow.channels | |
io.undertow.client | |
io.undertow.client.http2 | |
io.undertow.conduits | |
io.undertow.protocols.ajp | |
io.undertow.protocols.http2 | |
io.undertow.protocols.ssl | |
io.undertow.server | |
io.undertow.server.handlers.cache | |
io.undertow.server.protocol.framed | |
io.undertow.server.protocol.http | |
io.undertow.servlet.spec | |
io.undertow.util | |
io.undertow.websockets.core | |
io.undertow.websockets.core.function | |
org.xnio |
The main API package for XNIO.
|
org.xnio.channels |
The core XNIO channel API.
|
org.xnio.conduits |
The XNIO conduit SPI.
|
org.xnio.streams |
Utility classes for creating streams which use XNIO channels.
|
Modifier and Type | Class and Description |
---|---|
class |
DetachableStreamSourceChannel
A stream source channel that can be marked as detached.
|
Modifier and Type | Field and Description |
---|---|
protected StreamSourceChannel |
DetachableStreamSourceChannel.delegate |
Modifier and Type | Method and Description |
---|---|
ChannelListener.Setter<? extends StreamSourceChannel> |
DetachableStreamSourceChannel.getCloseSetter() |
ChannelListener.Setter<? extends StreamSourceChannel> |
DetachableStreamSourceChannel.getReadSetter() |
Modifier and Type | Method and Description |
---|---|
long |
DetachableStreamSinkChannel.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
Constructor and Description |
---|
DetachableStreamSourceChannel(StreamSourceChannel delegate) |
Modifier and Type | Method and Description |
---|---|
StreamSourceChannel |
ClientExchange.getResponseChannel()
Returns the response channel that can be used to read data from the target server.
|
Modifier and Type | Method and Description |
---|---|
StreamSourceChannel |
Http2ClientExchange.getResponseChannel() |
Modifier and Type | Method and Description |
---|---|
long |
WriteTimeoutStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
StoredResponseStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
RateLimitingStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
RangeStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
PreChunkedStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
IdleTimeoutConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
HeadStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
DeflatingStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
DebuggingStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
ChunkedStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
BytesSentStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
AbstractFramedStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
AbstractFixedLengthStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAjpClientStreamSourceChannel |
class |
AjpClientResponseStreamSourceChannel |
Modifier and Type | Class and Description |
---|---|
class |
AbstractHttp2StreamSourceChannel
HTTP2 stream source channel
|
class |
Http2GoAwayStreamSourceChannel
A HTTP2 go away frame
|
class |
Http2PingStreamSourceChannel
A HTTP2 Ping frame
|
class |
Http2PushPromiseStreamSourceChannel
A HTTP2 push promise frame
|
class |
Http2RstStreamStreamSourceChannel
A HTTP2 RST Stream channel
|
class |
Http2SettingsStreamSourceChannel
A HTTP2 Settings frame
|
class |
Http2StreamSourceChannel |
Modifier and Type | Method and Description |
---|---|
long |
SslConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
Modifier and Type | Method and Description |
---|---|
static StreamSourceChannel |
Connectors.getExistingRequestChannel(HttpServerExchange exchange)
Returns the existing request channel, if it exists.
|
StreamSourceChannel |
HttpServerExchange.getRequestChannel()
Get the inbound request.
|
Modifier and Type | Method and Description |
---|---|
long |
ResponseCachingStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFramedStreamSourceChannel<C extends AbstractFramedChannel<C,R,S>,R extends AbstractFramedStreamSourceChannel<C,R,S>,S extends AbstractFramedStreamSinkChannel<C,R,S>>
Source channel, used to receive framed messages.
|
Modifier and Type | Method and Description |
---|---|
long |
AbstractFramedStreamSinkChannel.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
Modifier and Type | Method and Description |
---|---|
long |
PipeliningBufferingStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
Constructor and Description |
---|
UpgradeServletInputStream(StreamSourceChannel channel,
ByteBufferPool bufferPool,
Executor ioExecutor) |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
StringReadChannelListener.handleEvent(StreamSourceChannel channel) |
void |
StringReadChannelListener.setup(StreamSourceChannel channel) |
Modifier and Type | Class and Description |
---|---|
class |
StreamSourceFrameChannel
Base class for processes Frame bases StreamSourceChannels.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
ChannelFunctionStreamSourceChannel |
Modifier and Type | Method and Description |
---|---|
ChannelListener.Setter<? extends StreamSourceChannel> |
ChannelFunctionStreamSourceChannel.getCloseSetter() |
ChannelListener.Setter<? extends StreamSourceChannel> |
ChannelFunctionStreamSourceChannel.getReadSetter() |
Constructor and Description |
---|
ChannelFunctionStreamSourceChannel(StreamSourceChannel channel,
ChannelFunction... functions) |
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 <I extends StreamSourceChannel,O extends StreamSinkChannel> |
ChannelListeners.initiateTransfer(I source,
O sink,
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.
|
Modifier and Type | Method and Description |
---|---|
protected StreamSourceChannel |
XnioWorker.getInflatingChannel(StreamSourceChannel delegate,
Inflater inflater)
Create a stream channel that decompresses the source data according to the configuration in the given inflater.
|
StreamSourceChannel |
XnioWorker.getInflatingChannel(StreamSourceChannel delegate,
OptionMap options)
Create a stream channel that decompresses the source data according to the configuration in the given option map.
|
Modifier and Type | Method and Description |
---|---|
ChannelPipe<StreamSourceChannel,StreamSinkChannel> |
XnioWorker.createHalfDuplexPipe() |
ChannelPipe<StreamSourceChannel,StreamSinkChannel> |
XnioIoThread.createHalfDuplexPipe() |
ChannelPipe<StreamSourceChannel,StreamSinkChannel> |
XnioIoFactory.createHalfDuplexPipe()
Create a one-way stream pipe.
|
ChannelPipe<StreamSourceChannel,StreamSinkChannel> |
XnioWorker.createHalfDuplexPipe(XnioIoFactory peer) |
ChannelPipe<StreamSourceChannel,StreamSinkChannel> |
XnioIoThread.createHalfDuplexPipe(XnioIoFactory peer) |
ChannelPipe<StreamSourceChannel,StreamSinkChannel> |
XnioIoFactory.createHalfDuplexPipe(XnioIoFactory peer)
Create a one-way stream pipe.
|
Modifier and Type | Method and Description |
---|---|
protected StreamSourceChannel |
XnioWorker.getInflatingChannel(StreamSourceChannel delegate,
Inflater inflater)
Create a stream channel that decompresses the source data according to the configuration in the given inflater.
|
StreamSourceChannel |
XnioWorker.getInflatingChannel(StreamSourceChannel delegate,
OptionMap options)
Create a stream channel that decompresses the source data according to the configuration in the given option map.
|
Modifier and Type | Method and Description |
---|---|
void |
XnioWorker.createOneWayPipe(ChannelListener<? super StreamSourceChannel> sourceListener,
ChannelListener<? super StreamSinkChannel> sinkListener,
OptionMap optionMap)
Deprecated.
Users should prefer the simpler
XnioWorker.createHalfDuplexPipe() instead. |
Modifier and Type | Interface and Description |
---|---|
interface |
ConnectedSslStreamChannel
A TLS-encapsulated connected stream channel.
|
interface |
ConnectedStreamChannel
A stream channel that is a connection between a local and remote endpoint.
|
interface |
StreamChannel
A stream channel.
|
Modifier and Type | Class and Description |
---|---|
class |
AssembledConnectedSslStreamChannel
A connected SSL stream channel assembled from a stream source and stream sink.
|
class |
AssembledConnectedStreamChannel
A connected stream channel assembled from a stream source and stream sink.
|
class |
AssembledStreamChannel
A stream channel assembled from a stream source and stream sink.
|
class |
EmptyStreamSourceChannel
A stream source channel which is always empty.
|
class |
FixedLengthStreamSourceChannel
A channel which reads data of a fixed length and calls a finish listener.
|
class |
PushBackStreamChannel
A stream source channel which can have data pushed back into it.
|
class |
SplitStreamSourceChannel
A half-duplex (read side) wrapper for a full-duplex channel.
|
Modifier and Type | Method and Description |
---|---|
StreamSourceChannel |
PushBackStreamChannel.getChannel() |
StreamSourceChannel |
FixedLengthStreamSourceChannel.getChannel(Object guard) |
Modifier and Type | Method and Description |
---|---|
ChannelListener.Setter<? extends StreamSourceChannel> |
StreamSourceChannel.getCloseSetter()
Get the setter which can be used to change the close listener for this channel.
|
ChannelListener.Setter<? extends StreamSourceChannel> |
StreamSourceChannel.getReadSetter()
Get the setter which can be used to change the read listener for this channel.
|
Modifier and Type | Method and Description |
---|---|
static long |
Channels.drain(StreamSourceChannel channel,
long count)
Attempt to drain the given number of bytes from the stream source channel.
|
static void |
Channels.transferBlocking(FileChannel destination,
StreamSourceChannel source,
long startPosition,
long count)
Transfer bytes between two channels efficiently, blocking if necessary.
|
static long |
Channels.transferBlocking(StreamSinkChannel destination,
StreamSourceChannel source,
ByteBuffer throughBuffer,
long count)
Transfer bytes between two channels efficiently, blocking if necessary.
|
long |
StreamSinkChannel.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer)
Transfers bytes from the given channel source.
|
long |
SplitStreamSinkChannel.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
NullStreamSinkChannel.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
FixedLengthStreamSinkChannel.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
AssembledStreamChannel.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
Constructor and Description |
---|
AssembledConnectedSslStreamChannel(SslChannel sslChannel,
StreamSourceChannel source,
StreamSinkChannel sink)
Construct a new instance.
|
AssembledConnectedSslStreamChannel(StreamSourceChannel source,
StreamSinkChannel sink)
Construct a new instance.
|
AssembledConnectedStreamChannel(ConnectedChannel connection,
StreamSourceChannel source,
StreamSinkChannel sink)
Construct a new instance.
|
AssembledConnectedStreamChannel(StreamSourceChannel source,
StreamSinkChannel sink)
Construct a new instance.
|
AssembledStreamChannel(CloseableChannel closeable,
StreamSourceChannel source,
StreamSinkChannel sink)
Construct a new instance.
|
AssembledStreamChannel(StreamSourceChannel source,
StreamSinkChannel sink)
Construct a new instance.
|
BlockingReadableByteChannel(StreamSourceChannel delegate)
Construct a new instance.
|
BlockingReadableByteChannel(StreamSourceChannel delegate,
long readTimeout,
TimeUnit readTimeoutUnit)
Construct a new instance.
|
FixedLengthStreamSourceChannel(StreamSourceChannel delegate,
long contentLength,
boolean configurable,
boolean propagateClose,
ChannelListener<? super FixedLengthStreamSourceChannel> finishListener,
Object guard)
Construct a new instance.
|
FixedLengthStreamSourceChannel(StreamSourceChannel delegate,
long contentLength,
boolean configurable,
ChannelListener<? super FixedLengthStreamSourceChannel> finishListener,
Object guard)
Construct a new instance.
|
FixedLengthStreamSourceChannel(StreamSourceChannel delegate,
long contentLength,
ChannelListener<? super FixedLengthStreamSourceChannel> finishListener,
Object guard)
Construct a new instance.
|
PushBackStreamChannel(StreamSourceChannel channel)
Construct a new instance.
|
SplitStreamSourceChannel(StreamSourceChannel delegate)
Construct a new instance which doesn't delegate configuration.
|
SplitStreamSourceChannel(StreamSourceChannel delegate,
boolean delegateConfig)
Construct a new instance.
|
Modifier and Type | Class and Description |
---|---|
class |
ConduitStreamSourceChannel
A stream source channel which wraps a stream source conduit.
|
Modifier and Type | Method and Description |
---|---|
long |
SynchronizedStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
StreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer)
Transfers bytes from the given channel source.
|
long |
StreamSinkChannelWrappingConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
NullStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
MessageStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
FixedLengthStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
DeflatingStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
ConduitStreamSinkChannel.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
BufferedStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
BlockingStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
long |
AbstractStreamSinkConduit.transferFrom(StreamSourceChannel source,
long count,
ByteBuffer throughBuffer) |
Constructor and Description |
---|
StreamSourceChannelWrappingConduit(StreamSourceChannel channel)
Construct a new instance.
|
Modifier and Type | Field and Description |
---|---|
protected StreamSourceChannel |
ChannelInputStream.channel |
Constructor and Description |
---|
BufferedChannelInputStream(StreamSourceChannel channel,
int bufferSize)
Construct a new instance.
|
BufferedChannelInputStream(StreamSourceChannel channel,
int bufferSize,
long timeout,
TimeUnit unit)
Construct a new instance.
|
ChannelInputStream(StreamSourceChannel channel)
Construct a new instance.
|
ChannelInputStream(StreamSourceChannel channel,
long timeout,
TimeUnit timeoutUnit)
Construct a new instance.
|
Copyright © 2017 JBoss by Red Hat. All rights reserved.