Package | Description |
---|---|
io.undertow.channels | |
io.undertow.client | |
io.undertow.client.http2 | |
io.undertow.conduits | |
io.undertow.io | |
io.undertow.protocols.ajp | |
io.undertow.protocols.http2 | |
io.undertow.protocols.ssl | |
io.undertow.server | |
io.undertow.server.handlers.sse | |
io.undertow.server.protocol.ajp | |
io.undertow.server.protocol.framed | |
io.undertow.servlet.spec | |
io.undertow.util | |
io.undertow.websockets.core | |
io.undertow.websockets.core.function | |
io.undertow.websockets.core.protocol.version07 | |
org.wildfly.httpclient.common | |
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 |
DetachableStreamSinkChannel
Stream sink channel.
|
Modifier and Type | Field and Description |
---|---|
protected StreamSinkChannel |
DetachableStreamSinkChannel.delegate |
Modifier and Type | Method and Description |
---|---|
ChannelListener.Setter<? extends StreamSinkChannel> |
DetachableStreamSinkChannel.getCloseSetter() |
ChannelListener.Setter<? extends StreamSinkChannel> |
DetachableStreamSinkChannel.getWriteSetter() |
Modifier and Type | Method and Description |
---|---|
long |
DetachableStreamSourceChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
Constructor and Description |
---|
DetachableStreamSinkChannel(StreamSinkChannel delegate) |
Modifier and Type | Method and Description |
---|---|
StreamSinkChannel |
ClientExchange.getRequestChannel()
Returns the request channel that can be used to send data to the server.
|
Modifier and Type | Method and Description |
---|---|
StreamSinkChannel |
Http2ClientExchange.getRequestChannel() |
Modifier and Type | Method and Description |
---|---|
long |
ReadTimeoutStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
ReadDataStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
InflatingStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
IdleTimeoutConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
FixedLengthStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
FinishableStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
EmptyStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
DebuggingStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
ChunkedStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
BytesReceivedStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
BrokenStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncSenderImpl.TransferTask.handleEvent(StreamSinkChannel channel) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAjpClientStreamSinkChannel |
class |
AjpClientRequestClientStreamSinkChannel
AJP stream sink channel that corresponds to a request send from the load balancer to the backend
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractHttp2StreamSinkChannel |
class |
Http2DataStreamSinkChannel
Headers channel
|
class |
Http2HeadersStreamSinkChannel
Headers channel
|
class |
Http2PushPromiseStreamSinkChannel
Push promise channel
|
class |
Http2SettingsStreamSinkChannel
//TODO: ack
|
class |
Http2StreamSinkChannel |
Modifier and Type | Method and Description |
---|---|
long |
Http2StreamSourceChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel streamSinkChannel) |
Modifier and Type | Method and Description |
---|---|
long |
SslConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
Modifier and Type | Method and Description |
---|---|
StreamSinkChannel |
HttpServerExchange.getResponseChannel()
Get the response channel.
|
Constructor and Description |
---|
ServerSentEventConnection(HttpServerExchange exchange,
StreamSinkChannel sink) |
Modifier and Type | Method and Description |
---|---|
long |
AjpServerRequestConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFramedStreamSinkChannel<C extends AbstractFramedChannel<C,R,S>,R extends AbstractFramedStreamSourceChannel<C,R,S>,S extends AbstractFramedStreamSinkChannel<C,R,S>>
Framed Stream Sink Channel.
|
Modifier and Type | Method and Description |
---|---|
long |
AbstractFramedStreamSourceChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel streamSinkChannel) |
Constructor and Description |
---|
UpgradeServletOutputStream(StreamSinkChannel channel,
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 |
---|---|
protected void |
StringWriteChannelListener.handleError(StreamSinkChannel channel,
IOException e) |
void |
StringWriteChannelListener.handleEvent(StreamSinkChannel channel) |
void |
StringWriteChannelListener.setup(StreamSinkChannel channel) |
protected void |
StringWriteChannelListener.writeDone(StreamSinkChannel channel) |
Modifier and Type | Class and Description |
---|---|
class |
StreamSinkFrameChannel |
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 | Method and Description |
---|---|
long |
StreamSourceFrameChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
Modifier and Type | Method and Description |
---|---|
long |
ChannelFunctionStreamSourceChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
Modifier and Type | Class and Description |
---|---|
class |
WebSocket07FrameSinkChannel
StreamSinkFrameChannel implementation for writing WebSocket Frames on WebSocketVersion.V08 connections |
Constructor and Description |
---|
WildflyClientOutputStream(StreamSinkChannel channel,
ByteBufferPool byteBufferPool) |
Modifier and Type | Method and Description |
---|---|
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 <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.
|
static <T extends StreamSinkChannel> |
ChannelListeners.writingChannelListener(Pooled<ByteBuffer> pooled,
ChannelListener<? super T> delegate,
ChannelExceptionHandler<? super T> exceptionHandler)
A writing channel listener.
|
Modifier and Type | Method and Description |
---|---|
protected StreamSinkChannel |
XnioWorker.getDeflatingChannel(StreamSinkChannel delegate,
Deflater deflater)
Create a stream channel that compresses to the destination according to the configuration in the given inflater.
|
StreamSinkChannel |
XnioWorker.getDeflatingChannel(StreamSinkChannel delegate,
OptionMap options)
Create a stream channel that compresses to the destination 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 StreamSinkChannel |
XnioWorker.getDeflatingChannel(StreamSinkChannel delegate,
Deflater deflater)
Create a stream channel that compresses to the destination according to the configuration in the given inflater.
|
StreamSinkChannel |
XnioWorker.getDeflatingChannel(StreamSinkChannel delegate,
OptionMap options)
Create a stream channel that compresses to the destination 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 |
FixedLengthStreamSinkChannel
A channel which writes a fixed amount of data.
|
class |
NullStreamSinkChannel
A bit-bucket stream sink channel.
|
class |
SplitStreamSinkChannel
A half-duplex (write side) wrapper for a full-duplex channel.
|
Modifier and Type | Method and Description |
---|---|
StreamSinkChannel |
FixedLengthStreamSinkChannel.getChannel(Object guard) |
Modifier and Type | Method and Description |
---|---|
ChannelListener.Setter<? extends StreamSinkChannel> |
StreamSinkChannel.getCloseSetter()
Get the setter which can be used to change the close listener for this channel.
|
ChannelListener.Setter<? extends StreamSinkChannel> |
StreamSinkChannel.getWriteSetter()
Get the setter which can be used to change the write listener for this channel.
|
Modifier and Type | Method and Description |
---|---|
static void |
Channels.transferBlocking(StreamSinkChannel destination,
FileChannel 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 |
StreamSourceChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target)
Transfers bytes into the given channel target.
|
long |
SplitStreamSourceChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
PushBackStreamChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
FixedLengthStreamSourceChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
EmptyStreamSourceChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
AssembledStreamChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
static int |
Channels.writeFinalBasic(StreamSinkChannel channel,
ByteBuffer src)
Writes out the data in the buffer to the channel.
|
static long |
Channels.writeFinalBasic(StreamSinkChannel channel,
ByteBuffer[] srcs,
int offset,
int length)
Writes out the data in the buffer to the channel.
|
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.
|
BlockingWritableByteChannel(StreamSinkChannel delegate)
Construct a new instance.
|
BlockingWritableByteChannel(StreamSinkChannel delegate,
long writeTimeout,
TimeUnit writeTimeoutUnit)
Construct a new instance.
|
FixedLengthStreamSinkChannel(StreamSinkChannel delegate,
long contentLength,
boolean configurable,
boolean propagateClose,
ChannelListener<? super FixedLengthStreamSinkChannel> finishListener,
Object guard)
Construct a new instance.
|
SplitStreamSinkChannel(StreamSinkChannel delegate)
Construct a new instance which does not delegate configuration.
|
SplitStreamSinkChannel(StreamSinkChannel delegate,
boolean delegateConfig)
Construct a new instance.
|
Modifier and Type | Class and Description |
---|---|
class |
ConduitStreamSinkChannel
A stream sink channel which wraps a stream sink conduit.
|
Modifier and Type | Method and Description |
---|---|
long |
SynchronizedStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
StreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target)
Transfers bytes into the given channel target.
|
long |
StreamSourceChannelWrappingConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
PushBackStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
MessageStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
InflatingStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
FixedLengthStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
EmptyStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
ConduitStreamSourceChannel.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
BufferedStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
BlockingStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
long |
AbstractStreamSourceConduit.transferTo(long count,
ByteBuffer throughBuffer,
StreamSinkChannel target) |
Constructor and Description |
---|
StreamSinkChannelWrappingConduit(StreamSinkChannel channel)
Construct a new instance.
|
Modifier and Type | Field and Description |
---|---|
protected StreamSinkChannel |
ChannelOutputStream.channel |
Constructor and Description |
---|
ChannelOutputStream(StreamSinkChannel channel)
Construct a new instance.
|
ChannelOutputStream(StreamSinkChannel channel,
long timeout,
TimeUnit unit)
Construct a new instance.
|
Copyright © 2017 JBoss by Red Hat. All rights reserved.