Uses of Interface
org.xnio.conduits.StreamSinkConduit

Packages that use StreamSinkConduit

Package	Description
io.undertow.conduits
io.undertow.protocols.ssl
io.undertow.server
io.undertow.server.handlers.cache
io.undertow.server.handlers.encoding
io.undertow.server.protocol.ajp
io.undertow.server.protocol.http
io.undertow.server.protocol.http2
org.xnio	The main API package for XNIO.
org.xnio.conduits	The XNIO conduit SPI.

Uses of StreamSinkConduit in io.undertow.conduits

Classes in io.undertow.conduits that implement StreamSinkConduit

Modifier and Type	Class and Description
class	AbstractFixedLengthStreamSinkConduit A channel which writes a fixed amount of data.
class	AbstractFramedStreamSinkConduit Utility class to ease the implementation of framed protocols.
class	BytesSentStreamSinkConduit
class	ChunkedStreamSinkConduit Channel that implements HTTP chunked transfer coding.
class	DebuggingStreamSinkConduit Conduit that saves all the data that is written through it and can dump it to the console
class	DeflatingStreamSinkConduit Channel that handles deflate compression
class	FinishableStreamSinkConduit
class	GzipStreamSinkConduit
class	HeadStreamSinkConduit A conduit that discards all data written to it.
class	IdleTimeoutConduit Conduit that adds support to close a channel once for a specified time no reads and no writes were performed.
class	PreChunkedStreamSinkConduit Channel that implements HTTP chunked transfer coding for data streams that already have chunk markers.
class	RangeStreamSinkConduit
class	RateLimitingStreamSinkConduit Class that implements the token bucket algorithm.
class	StoredResponseStreamSinkConduit
class	WriteTimeoutStreamSinkConduit Wrapper for write timeout.

Constructors in io.undertow.conduits with parameters of type StreamSinkConduit

Constructor and Description
AbstractFixedLengthStreamSinkConduit(StreamSinkConduit next, long contentLength, boolean configurable, boolean propagateClose) Construct a new instance.
AbstractFramedStreamSinkConduit(StreamSinkConduit next) Construct a new instance.
BytesSentStreamSinkConduit(StreamSinkConduit next, ByteActivityCallback callback) Construct a new instance.
ChunkedStreamSinkConduit(StreamSinkConduit next, ByteBufferPool bufferPool, boolean configurable, boolean passClose, HeaderMap responseHeaders, ConduitListener<? super ChunkedStreamSinkConduit> finishListener, Attachable attachable) Construct a new instance.
DebuggingStreamSinkConduit(StreamSinkConduit next) Construct a new instance.
FinishableStreamSinkConduit(StreamSinkConduit delegate, ConduitListener<? super FinishableStreamSinkConduit> finishListener)
HeadStreamSinkConduit(StreamSinkConduit next, ConduitListener<? super HeadStreamSinkConduit> finishListener) Construct a new instance.
HeadStreamSinkConduit(StreamSinkConduit next, ConduitListener<? super HeadStreamSinkConduit> finishListener, boolean shutdownDelegate) Construct a new instance.
PreChunkedStreamSinkConduit(StreamSinkConduit next, ConduitListener<? super PreChunkedStreamSinkConduit> finishListener, Attachable attachable) Construct a new instance.
RangeStreamSinkConduit(StreamSinkConduit next, long start, long end, long originalResponseLength)
RateLimitingStreamSinkConduit(StreamSinkConduit next, int bytes, long time, TimeUnit timeUnit)
StoredResponseStreamSinkConduit(StreamSinkConduit next, HttpServerExchange exchange) Construct a new instance.
WriteTimeoutStreamSinkConduit(StreamSinkConduit delegate, StreamConnection connection, OpenListener openListener)

Constructor parameters in io.undertow.conduits with type arguments of type StreamSinkConduit

Constructor and Description
DeflatingStreamSinkConduit(ConduitFactory<StreamSinkConduit> conduitFactory, HttpServerExchange exchange)
DeflatingStreamSinkConduit(ConduitFactory<StreamSinkConduit> conduitFactory, HttpServerExchange exchange, int deflateLevel)
GzipStreamSinkConduit(ConduitFactory<StreamSinkConduit> conduitFactory, HttpServerExchange exchange)
GzipStreamSinkConduit(ConduitFactory<StreamSinkConduit> conduitFactory, HttpServerExchange exchange, int deflateLevel)

Uses of StreamSinkConduit in io.undertow.protocols.ssl

Classes in io.undertow.protocols.ssl that implement StreamSinkConduit

Modifier and Type	Class and Description
class	SslConduit

Uses of StreamSinkConduit in io.undertow.server

Fields in io.undertow.server declared as StreamSinkConduit

Modifier and Type	Field and Description
protected StreamSinkConduit	AbstractServerConnection.originalSinkConduit

Methods in io.undertow.server that return StreamSinkConduit

Modifier and Type	Method and Description
StreamSinkConduit	HttpServerExchange.WrapperStreamSinkConduitFactory.create()
StreamSinkConduit	AbstractServerConnection.getOriginalSinkConduit()
protected abstract StreamSinkConduit	ServerConnection.getSinkConduit(HttpServerExchange exchange, StreamSinkConduit conduit) Gets the sink conduit that should be used for this request.
protected static StreamSinkConduit	AbstractServerConnection.sink(AbstractServerConnection.ConduitState state)

Methods in io.undertow.server with parameters of type StreamSinkConduit

Modifier and Type	Method and Description
protected abstract StreamSinkConduit	ServerConnection.getSinkConduit(HttpServerExchange exchange, StreamSinkConduit conduit) Gets the sink conduit that should be used for this request.

Method parameters in io.undertow.server with type arguments of type StreamSinkConduit

Modifier and Type	Method and Description
HttpServerExchange	HttpServerExchange.addResponseWrapper(ConduitWrapper<StreamSinkConduit> wrapper) Adds a ConduitWrapper to the response wrapper chain.

Constructors in io.undertow.server with parameters of type StreamSinkConduit

Constructor and Description
WrapperStreamSinkConduitFactory(ConduitWrapper<StreamSinkConduit>[] wrappers, int wrapperCount, HttpServerExchange exchange, StreamSinkConduit first)

Uses of StreamSinkConduit in io.undertow.server.handlers.cache

Classes in io.undertow.server.handlers.cache that implement StreamSinkConduit

Modifier and Type	Class and Description
class	ResponseCachingStreamSinkConduit

Constructors in io.undertow.server.handlers.cache with parameters of type StreamSinkConduit

Constructor and Description
ResponseCachingStreamSinkConduit(StreamSinkConduit next, DirectBufferCache.CacheEntry cacheEntry, long length) Construct a new instance.

Uses of StreamSinkConduit in io.undertow.server.handlers.encoding

Methods in io.undertow.server.handlers.encoding that return StreamSinkConduit

Modifier and Type	Method and Description
StreamSinkConduit	AllowedContentEncodings.wrap(ConduitFactory<StreamSinkConduit> factory, HttpServerExchange exchange)

Methods in io.undertow.server.handlers.encoding that return types with arguments of type StreamSinkConduit

Modifier and Type	Method and Description
ConduitWrapper<StreamSinkConduit>	GzipEncodingProvider.getResponseWrapper()
ConduitWrapper<StreamSinkConduit>	DeflateEncodingProvider.getResponseWrapper()
ConduitWrapper<StreamSinkConduit>	ContentEncodingProvider.getResponseWrapper()

Method parameters in io.undertow.server.handlers.encoding with type arguments of type StreamSinkConduit

Modifier and Type	Method and Description
StreamSinkConduit	AllowedContentEncodings.wrap(ConduitFactory<StreamSinkConduit> factory, HttpServerExchange exchange)

Uses of StreamSinkConduit in io.undertow.server.protocol.ajp

Methods in io.undertow.server.protocol.ajp that return StreamSinkConduit

Modifier and Type	Method and Description
protected StreamSinkConduit	AjpServerConnection.getSinkConduit(HttpServerExchange exchange, StreamSinkConduit conduit)

Methods in io.undertow.server.protocol.ajp with parameters of type StreamSinkConduit

Modifier and Type	Method and Description
protected StreamSinkConduit	AjpServerConnection.getSinkConduit(HttpServerExchange exchange, StreamSinkConduit conduit)

Uses of StreamSinkConduit in io.undertow.server.protocol.http

Classes in io.undertow.server.protocol.http that implement StreamSinkConduit

Modifier and Type	Class and Description
class	PipeliningBufferingStreamSinkConduit A buffer that is used when processing pipelined requests, that allows the server to buffer multiple responses into a single write() call.
class	ServerFixedLengthStreamSinkConduit

Methods in io.undertow.server.protocol.http that return StreamSinkConduit

Modifier and Type	Method and Description
protected StreamSinkConduit	HttpServerConnection.getSinkConduit(HttpServerExchange exchange, StreamSinkConduit conduit)

Methods in io.undertow.server.protocol.http with parameters of type StreamSinkConduit

Modifier and Type	Method and Description
protected StreamSinkConduit	HttpServerConnection.getSinkConduit(HttpServerExchange exchange, StreamSinkConduit conduit)

Constructors in io.undertow.server.protocol.http with parameters of type StreamSinkConduit

Constructor and Description
PipeliningBufferingStreamSinkConduit(StreamSinkConduit next, ByteBufferPool pool)
ServerFixedLengthStreamSinkConduit(StreamSinkConduit next, boolean configurable, boolean propagateClose) Construct a new instance.

Uses of StreamSinkConduit in io.undertow.server.protocol.http2

Methods in io.undertow.server.protocol.http2 that return StreamSinkConduit

Modifier and Type	Method and Description
protected StreamSinkConduit	Http2ServerConnection.getSinkConduit(HttpServerExchange exchange, StreamSinkConduit conduit)

Methods in io.undertow.server.protocol.http2 with parameters of type StreamSinkConduit

Modifier and Type	Method and Description
protected StreamSinkConduit	Http2ServerConnection.getSinkConduit(HttpServerExchange exchange, StreamSinkConduit conduit)

Uses of StreamSinkConduit in org.xnio

Methods in org.xnio with parameters of type StreamSinkConduit

Modifier and Type	Method and Description
protected void	StreamConnection.setSinkConduit(StreamSinkConduit conduit) Set the sink conduit for this channel.

Uses of StreamSinkConduit in org.xnio.conduits

Classes in org.xnio.conduits with type parameters of type StreamSinkConduit

Modifier and Type	Class and Description
class	AbstractStreamSinkConduit<D extends StreamSinkConduit> An abstract base class for filtering stream sink conduits.

Classes in org.xnio.conduits that implement StreamSinkConduit

Modifier and Type	Class and Description
class	AbstractStreamSinkConduit<D extends StreamSinkConduit> An abstract base class for filtering stream sink conduits.
class	BlockingStreamSinkConduit
class	BufferedStreamSinkConduit A stream sink conduit that buffers output data.
class	FixedLengthStreamSinkConduit A stream sink conduit with a limited length.
class	MessageStreamSinkConduit A stream sink conduit which wraps each write into a single message.
class	NullStreamSinkConduit A stream sink conduit which discards all data written to it.
class	StreamSinkChannelWrappingConduit A conduit which wraps a channel, for compatibility.
class	SynchronizedStreamSinkConduit A synchronized stream sink conduit.

Methods in org.xnio.conduits that return StreamSinkConduit

Modifier and Type	Method and Description
StreamSinkConduit	ConduitStreamSinkChannel.getConduit() Get the underlying conduit for this channel.

Methods in org.xnio.conduits with parameters of type StreamSinkConduit

Modifier and Type	Method and Description
void	ConduitStreamSinkChannel.setConduit(StreamSinkConduit conduit) Set the underlying conduit for this channel.
static long	Conduits.transfer(ReadableByteChannel source, long count, ByteBuffer throughBuffer, StreamSinkConduit sink) Platform-independent channel-to-channel transfer method.
static int	Conduits.writeFinalBasic(StreamSinkConduit conduit, ByteBuffer src) Writes the buffer to the conduit, and terminates writes if all the data is written
static long	Conduits.writeFinalBasic(StreamSinkConduit conduit, ByteBuffer[] srcs, int offset, int length) Writes the buffer to the conduit, and terminates writes if all the data is written

Constructors in org.xnio.conduits with parameters of type StreamSinkConduit

Constructor and Description
BlockingStreamSinkConduit(StreamSinkConduit next)
BufferedStreamSinkConduit(StreamSinkConduit next, Pooled<ByteBuffer> pooledBuffer) Construct a new instance.
ConduitStreamSinkChannel(Configurable configurable, StreamSinkConduit conduit) Construct a new instance.
ConduitWritableByteChannel(StreamSinkConduit conduit) Construct a new instance.
DeflatingStreamSinkConduit(StreamSinkConduit next, Deflater deflater) Construct a new instance.
FramingMessageSinkConduit(StreamSinkConduit next, boolean longLengths, Pooled<ByteBuffer> transmitBuffer) Construct a new instance.
SynchronizedStreamSinkConduit(StreamSinkConduit next) Construct a new instance.
SynchronizedStreamSinkConduit(StreamSinkConduit next, Object lock) Construct a new instance.