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 StreamSourceChannelXnioWorker.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 StreamSourceChannelXnioWorker.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 TypeMethodDescriptionvoidXnioWorker.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 TypeInterfaceDescriptioninterfaceA TLS-encapsulated connected stream channel.interfaceA stream channel that is a connection between a local and remote endpoint.interfaceA stream channel.Classes in org.xnio.channels that implement StreamSourceChannelModifier and TypeClassDescriptionclassA connected SSL stream channel assembled from a stream source and stream sink.classA connected stream channel assembled from a stream source and stream sink.classA stream channel assembled from a stream source and stream sink.classA stream source channel which is always empty.final classA channel which reads data of a fixed length and calls a finish listener.final classA stream source channel which can have data pushed back into it.final classA 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 longChannels.drain(StreamSourceChannel channel, long count) Attempt to drain the given number of bytes from the stream source channel.static voidChannels.transferBlocking(FileChannel destination, StreamSourceChannel source, long startPosition, long count) Transfer bytes between two channels efficiently, blocking if necessary.static longChannels.transferBlocking(StreamSinkChannel destination, StreamSourceChannel source, ByteBuffer throughBuffer, long count) Transfer bytes between two channels efficiently, blocking if necessary.longAssembledStreamChannel.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longFixedLengthStreamSinkChannel.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longNullStreamSinkChannel.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longSplitStreamSinkChannel.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longStreamSinkChannel.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 classA stream source channel which wraps a stream source conduit.Methods in org.xnio.conduits with parameters of type StreamSourceChannelModifier and TypeMethodDescriptionlongAbstractStreamSinkConduit.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longBlockingStreamSinkConduit.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longBufferedStreamSinkConduit.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longConduitStreamSinkChannel.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longDeflatingStreamSinkConduit.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longFixedLengthStreamSinkConduit.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longMessageStreamSinkConduit.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longNullStreamSinkConduit.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longStreamSinkChannelWrappingConduit.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) longStreamSinkConduit.transferFrom(StreamSourceChannel source, long count, ByteBuffer throughBuffer) Transfers bytes from the given channel source.longSynchronizedStreamSinkConduit.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.