Uses of Interface
net.sf.asyncobjects.io.AInput

Packages that use AInput

net.sf.asyncobjects.io	This package contains core IO interfaces.
net.sf.asyncobjects.io.adapters	This package contains adapters to blocking java streams.
net.sf.asyncobjects.io.util	This package contains uitility input and output streams.
net.sf.asyncobjects.net.nio	This package contains implementation of network interfaces that is based on non-blocking NIO socket API.
net.sf.asyncobjects.net.threading	This package contains implementation of network interfaces that is based on blocking socket API.

Uses of AInput in net.sf.asyncobjects.io

Classes in net.sf.asyncobjects.io with type parameters of type AInput

interface	AChannel<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>> A generic channel interface
class	BufferedInput<D extends BatchedData<D>,I extends AInput<D>> A buffered input stream.
class	Pipe<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>,C extends AChannel<D,I,O>> A pipe is pair of output stream and input stream, what is written to output stream, could be later read from input stream.
class	WrappingChannel<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>,C extends AChannel<D,I,O>> Byte channel that wraps existing channel some functionality over it.

Subinterfaces of AInput in net.sf.asyncobjects.io

interface	AByteInput Input stream interface
interface	ATextInput A text input.

Classes in net.sf.asyncobjects.io that implement AInput

class	BufferedByteInput A buffered byte input stream.
class	BufferedInput<D extends BatchedData<D>,I extends AInput<D>> A buffered input stream.
class	BufferedTextInput A buffered Text input stream.
class	BytePipe.InternalBytePipeInput Pipe input
class	DecoderTextInput A text input that uses CharsetDecoder to convert byte input to character input.
class	Pipe.InternalPipeInput This is an internal class.
class	TextPipe.InternalTextPipeInput Pipe input

Fields in net.sf.asyncobjects.io declared as AInput

protected I

WrappingChannel.in an input

Methods in net.sf.asyncobjects.io with parameters of type AInput

static <D extends BatchedData<D>> Promise<Integer>	IOUtils.compare(AInput<D> in1, AInput<D> in2, int readSize) Compare inputs.
static <D extends BatchedData<D>> Promise<Integer>	IOUtils.compare(AInput<D> in1, AInput<D> in2, int readSize) Compare inputs.
static <D extends BatchedData<D>> Promise<Long>	IOUtils.discard(AInput<D> in, long length, int readDataSize) Discard specified amount of elements from input.
static <D extends BatchedData<D>> Promise<Long>	IOUtils.forward(AInput<D> in, AOutput<D> out, long length, int readDataSize) Forward data from input to output
static <D extends BatchedData<D>> Promise<Long>	IOUtils.forward(AInput<D> in, AOutput<D> out, long length, int readDataSize, boolean autoflush) Forward data from input to output
static <D extends BatchedData<D>> Promise<D>	IOUtils.readAll(D initial, AInput<D> in, int limit) Read all data from the stream.
static <D extends BatchedData<D>> Promise<D>	IOUtils.readFully(D empty, AInput<D> in, int amount) Read exactly specified amount data from byte input

Uses of AInput in net.sf.asyncobjects.io.adapters

Classes in net.sf.asyncobjects.io.adapters that implement AInput

class

InputStreamAdapter Adapter for input stream

Uses of AInput in net.sf.asyncobjects.io.util

Classes in net.sf.asyncobjects.io.util with type parameters of type AInput

class	BoundedInput<D extends BatchedData<D>,I extends AInput<D>> Input that allows to read at most the specified length.
class	ExhaustingInput<D extends BatchedData<D>,I extends AInput<D>> This input waits until stream is fully readed.
class	GeneratingInput<D extends BatchedData<D>,I extends AInput<D>> A input that generates some data.
class	NulInput<D extends BatchedData<D>,I extends AInput<D>> A zero lenght stream.
class	RepeatingInput<D extends BatchedData<D>,I extends AInput<D>> An input that repeats specified data over and over.
class	SavingInput<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>> This utility stream allows to save all data read from byte input to some output.
class	UncloseableInput<D extends BatchedData<D>,I extends AInput<D>> A stream that instead of closing underlying stream just resolves CloseableWrapper.closed() promise.

Classes in net.sf.asyncobjects.io.util that implement AInput

class	BoundedByteInput Bounded byte input.
class	BoundedInput<D extends BatchedData<D>,I extends AInput<D>> Input that allows to read at most the specified length.
class	BoundedTextInput Bounded Text input.
class	ExhaustingByteInput Byte version of ExhaustingInput.
class	ExhaustingInput<D extends BatchedData<D>,I extends AInput<D>> This input waits until stream is fully readed.
class	ExhaustingTextInput Text version of ExhaustingInput.
class	GeneratingInput<D extends BatchedData<D>,I extends AInput<D>> A input that generates some data.
class	NulByteInput A nul byte input.
class	NulInput<D extends BatchedData<D>,I extends AInput<D>> A zero lenght stream.
class	NulTextInput A nul text input.
class	RandomByteInput A random byte input.
class	RandomTextInput A random text input.
class	RepeatingByteInput A repeating byte input
class	RepeatingInput<D extends BatchedData<D>,I extends AInput<D>> An input that repeats specified data over and over.
class	RepeatingTextInput A repeating text input.
class	SavingByteInput A saving byte input
class	SavingInput<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>> This utility stream allows to save all data read from byte input to some output.
class	SavingTextInput A saving text input
class	UncloseableByteInput Uncloseable byte input
class	UncloseableInput<D extends BatchedData<D>,I extends AInput<D>> A stream that instead of closing underlying stream just resolves CloseableWrapper.closed() promise.
class	UncloseableTextInput Uncloseable text input

Uses of AInput in net.sf.asyncobjects.net.nio

Classes in net.sf.asyncobjects.net.nio that implement AInput

class

NIOSocketInputStream implementation of stream for sockets

Uses of AInput in net.sf.asyncobjects.net.threading

Classes in net.sf.asyncobjects.net.threading that implement AInput

class

TSocket.TInputStreamAdapter Adapter for socket's input stream.