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

Packages that use BatchedData

net.sf.asyncobjects.io	This package contains core IO interfaces.
net.sf.asyncobjects.io.util	This package contains uitility input and output streams.

Uses of BatchedData in net.sf.asyncobjects.io

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

interface	AChannel<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>> A generic channel interface
interface	AInput<D extends BatchedData<D>> A generic input interface
interface	AOutput<D extends BatchedData<D>> A generic output interface.
interface	BatchedData<D extends BatchedData<D>> A batched data interface.
class	BufferedInput<D extends BatchedData<D>,I extends AInput<D>> A buffered input stream.
class	BufferedOutput<D extends BatchedData<D>,O extends AOutput<D>> Buffered output.
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.

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

class	BinaryData Immutable binary data class.
class	TextData A textual data batch.

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

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
static <D extends BatchedData<D>> Promise<Long>	IOUtils.repeat(AOutput<D> out, D data, long length) Write specified binary data repeating it until length bytes are written.

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

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

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	MulticastOutput<D extends BatchedData<D>,O extends AOutput<D>> A stream that copies data written to it into streams passed to it as arguments.
class	NulInput<D extends BatchedData<D>,I extends AInput<D>> A zero lenght stream.
class	RecordingOutput<D extends BatchedData<D>,O extends AOutput<D>> The output that recordes what is written into it.
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.