Uses of Interface
org.xnio.channels.StreamSourceChannel
Packages that use StreamSourceChannel
Package
Description
The main API package for XNIO.
The core XNIO channel API.
The XNIO conduit SPI.
Utility classes for creating streams which use XNIO channels.
-
Uses of StreamSourceChannel in org.xnio
Methods in org.xnio with type parameters of type StreamSourceChannelModifier and TypeMethodDescriptionstatic <T extends StreamSourceChannel>
ChannelListener<T>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>
ChannelListener<T>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>
voidChannelListeners.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>
voidChannelListeners.initiateTransfer
(I source, O sink, Pool<ByteBuffer> pool) Initiate a low-copy transfer between two stream channels.Methods in org.xnio that return StreamSourceChannelModifier and TypeMethodDescriptionprotected StreamSourceChannel
XnioWorker.getInflatingChannel
(StreamSourceChannel delegate, Inflater inflater) Create a stream channel that decompresses the source data according to the configuration in the given inflater.XnioWorker.getInflatingChannel
(StreamSourceChannel delegate, OptionMap options) Create a stream channel that decompresses the source data according to the configuration in the given option map.Methods in org.xnio that return types with arguments of type StreamSourceChannelModifier and TypeMethodDescriptionXnioIoFactory.createHalfDuplexPipe()
Create a one-way stream pipe.XnioIoFactory.createHalfDuplexPipe
(XnioIoFactory peer) Create a one-way stream pipe.XnioIoThread.createHalfDuplexPipe()
XnioIoThread.createHalfDuplexPipe
(XnioIoFactory peer) XnioWorker.createHalfDuplexPipe()
XnioWorker.createHalfDuplexPipe
(XnioIoFactory peer) Methods in org.xnio with parameters of type StreamSourceChannelModifier and TypeMethodDescriptionprotected StreamSourceChannel
XnioWorker.getInflatingChannel
(StreamSourceChannel delegate, Inflater inflater) Create a stream channel that decompresses the source data according to the configuration in the given inflater.XnioWorker.getInflatingChannel
(StreamSourceChannel delegate, OptionMap options) Create a stream channel that decompresses the source data according to the configuration in the given option map.Method parameters in org.xnio with type arguments of type StreamSourceChannelModifier and TypeMethodDescriptionvoid
XnioWorker.createOneWayPipe
(ChannelListener<? super StreamSourceChannel> sourceListener, ChannelListener<? super StreamSinkChannel> sinkListener, OptionMap optionMap) Deprecated. -
Uses of StreamSourceChannel in org.xnio.channels
Subinterfaces of StreamSourceChannel in org.xnio.channelsModifier and TypeInterfaceDescriptioninterface
A TLS-encapsulated connected stream channel.interface
A stream channel that is a connection between a local and remote endpoint.interface
A stream channel.Classes in org.xnio.channels that implement StreamSourceChannelModifier and TypeClassDescriptionclass
A connected SSL stream channel assembled from a stream source and stream sink.class
A connected stream channel assembled from a stream source and stream sink.class
A stream channel assembled from a stream source and stream sink.class
A stream source channel which is always empty.final class
A channel which reads data of a fixed length and calls a finish listener.final class
A stream source channel which can have data pushed back into it.final class
A half-duplex (read side) wrapper for a full-duplex channel.Methods in org.xnio.channels that return StreamSourceChannelModifier and TypeMethodDescriptionFixedLengthStreamSourceChannel.getChannel
(Object guard) PushBackStreamChannel.getChannel()
Methods in org.xnio.channels that return types with arguments of type StreamSourceChannelModifier and TypeMethodDescriptionChannelListener.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.Methods in org.xnio.channels with parameters of type StreamSourceChannelModifier and TypeMethodDescriptionstatic 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
AssembledStreamChannel.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
FixedLengthStreamSinkChannel.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
NullStreamSinkChannel.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
SplitStreamSinkChannel.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
StreamSinkChannel.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) Transfers bytes from the given channel source.Constructors in org.xnio.channels with parameters of type StreamSourceChannelModifierConstructorDescriptionAssembledConnectedSslStreamChannel
(SslChannel sslChannel, StreamSourceChannel source, StreamSinkChannel sink) Construct a new instance.Construct a new instance.AssembledConnectedStreamChannel
(ConnectedChannel connection, StreamSourceChannel source, StreamSinkChannel sink) Construct a new instance.Construct a new instance.AssembledStreamChannel
(CloseableChannel closeable, StreamSourceChannel source, StreamSinkChannel sink) Construct a new instance.AssembledStreamChannel
(StreamSourceChannel source, StreamSinkChannel sink) Construct a new instance.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. -
Uses of StreamSourceChannel in org.xnio.conduits
Classes in org.xnio.conduits that implement StreamSourceChannelModifier and TypeClassDescriptionfinal class
A stream source channel which wraps a stream source conduit.Methods in org.xnio.conduits with parameters of type StreamSourceChannelModifier and TypeMethodDescriptionlong
AbstractStreamSinkConduit.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
BlockingStreamSinkConduit.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
BufferedStreamSinkConduit.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
ConduitStreamSinkChannel.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
DeflatingStreamSinkConduit.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
FixedLengthStreamSinkConduit.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
MessageStreamSinkConduit.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
NullStreamSinkConduit.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
StreamSinkChannelWrappingConduit.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) long
StreamSinkConduit.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) Transfers bytes from the given channel source.long
SynchronizedStreamSinkConduit.transferFrom
(StreamSourceChannel source, long count, ByteBuffer throughBuffer) Constructors in org.xnio.conduits with parameters of type StreamSourceChannelModifierConstructorDescriptionConstruct a new instance. -
Uses of StreamSourceChannel in org.xnio.streams
Fields in org.xnio.streams declared as StreamSourceChannelConstructors in org.xnio.streams with parameters of type StreamSourceChannelModifierConstructorDescriptionBufferedChannelInputStream
(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.
XnioWorker.createHalfDuplexPipe()
instead.