A B C D E F G H I L M N O P Q R S T U V W

A

AByteChannel - Interface in net.sf.asyncobjects.io

An IO channel with input and output stream.

AByteInput - Interface in net.sf.asyncobjects.io

Input stream interface

AByteOutput - Interface in net.sf.asyncobjects.io

Output stream interface.

ACallable<T> - Interface in net.sf.asyncobjects.util.callbacks

An asynchronous action that might return a result.

accept() - Method in interface net.sf.asyncobjects.net.AServerSocket

Accept incomming connection

accept() - Method in class net.sf.asyncobjects.net.nio.NIOServerSocket

Accept connection

accept() - Method in class net.sf.asyncobjects.net.threading.TServerSocket

Accept connection for the socket

accepted(ACallable<Boolean>) - Method in interface net.sf.asyncobjects.util.timer.ATimerTask

This method is called when task were accepted to timer

accepted(ACallable<Boolean>) - Method in class net.sf.asyncobjects.util.timer.TimerTaskAdapter.InternalTimerTask

AChannel<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>> - Interface in net.sf.asyncobjects.io

A generic channel interface

ACloseable - Interface in net.sf.asyncobjects

The object that should be closed after it is no more used.

acquire() - Method in interface net.sf.asyncobjects.util.ASemaphore

acquire(int) - Method in interface net.sf.asyncobjects.util.ASemaphore

Aquiree a number of permits

acquire() - Method in class net.sf.asyncobjects.util.Semaphore

acquire(int) - Method in class net.sf.asyncobjects.util.Semaphore

Adapters - Class in net.sf.asyncobjects.io.adapters

IO Adapter utility class

Adapters() - Constructor for class net.sf.asyncobjects.io.adapters.Adapters

advanceNext() - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

Subclasses call this method to ensure that iterator could move further

afterInvalidate(Throwable) - Method in class net.sf.asyncobjects.io.util.ExhaustingInput

afterInvalidate(Throwable) - Method in class net.sf.asyncobjects.util.CloseableWrapper

Perform additional invalidation for the stream.

AInput<D extends BatchedData<D>> - Interface in net.sf.asyncobjects.io

A generic input interface

AListener<Event> - Interface in net.sf.asyncobjects.util.callbacks

A generic oneway listener interface.

All - Class in net.sf.asyncobjects.util

This control construct waits for all child actions.

All() - Constructor for class net.sf.asyncobjects.util.All

A constructor

all(Promise<?>...) - Static method in class net.sf.asyncobjects.util.Wait

This method allows waiting until operations represented by promises will finish.

allWritten() - Method in class net.sf.asyncobjects.io.util.SavingInput

AMapper<I,O> - Interface in net.sf.asyncobjects.util.callbacks

Interface for object that asynchronously maps one value to another

and(Promise<Boolean>...) - Static method in class net.sf.asyncobjects.util.Condition

This operations finishes with true only if all promises resolve to true.

Any - Class in net.sf.asyncobjects.util

This class allows to get first ready value out of number of alternatives.

Any(boolean) - Constructor for class net.sf.asyncobjects.util.Any

A constructor

Any() - Constructor for class net.sf.asyncobjects.util.Any

A constructor.

any(boolean, Iterator<Object>) - Static method in class net.sf.asyncobjects.util.Wait

Calculate first ready value of failure from the iterator.

any(boolean, Collection<?>) - Static method in class net.sf.asyncobjects.util.Wait

A utilty variant of Wait.any(boolean, Iterator) method that gets a Collection as argument.

any(boolean, Object[]) - Static method in class net.sf.asyncobjects.util.Wait

A utilty variant of Wait.any(boolean, Iterator) method that gets an array as argument.

AOutput<D extends BatchedData<D>> - Interface in net.sf.asyncobjects.io

A generic output interface.

append(BinaryData) - Method in class net.sf.asyncobjects.io.BinaryDataBuilder

Append binary data

append(byte) - Method in class net.sf.asyncobjects.io.BinaryDataBuilder

Append 8-bit byte

append(short) - Method in class net.sf.asyncobjects.io.BinaryDataBuilder

Append 16-bit integer

append(int) - Method in class net.sf.asyncobjects.io.BinaryDataBuilder

Append 32-bit integer

append(long) - Method in class net.sf.asyncobjects.io.BinaryDataBuilder

Append 64-bit integer

append(float) - Method in class net.sf.asyncobjects.io.BinaryDataBuilder

Append 32-bit IEEE float

append(double) - Method in class net.sf.asyncobjects.io.BinaryDataBuilder

Append 64-bit IEEE float

appendASCII(String) - Method in class net.sf.asyncobjects.io.BinaryDataBuilder

Append string in ASCII form.

appendASCII(char) - Method in class net.sf.asyncobjects.io.BinaryDataBuilder

Append character in ascii form

AQueue<T> - Interface in net.sf.asyncobjects.util

Object queue service.

AResolver<T> - Interface in net.sf.asyncobjects

This is a fundamental interface that is used to return values from operation.

ARunnable - Interface in net.sf.asyncobjects.util.callbacks

An asynchronous runnable interface for oneway notifications.

ASemaphore - Interface in net.sf.asyncobjects.util

This is an asynchronous version of Semaphore.

AServerSocket - Interface in net.sf.asyncobjects.net

A wrapper for server socket

ASocket - Interface in net.sf.asyncobjects.net

A socket wrapper interface

ASocketFactory - Interface in net.sf.asyncobjects.net

A factory for sockets

AsyncAction<T> - Class in net.sf.asyncobjects

Asynchronous action.

AsyncAction() - Constructor for class net.sf.asyncobjects.AsyncAction

AsyncCreator<R extends AsyncObject> - Class in net.sf.asyncobjects

Utility class that allows creating objects in other vats.

AsyncCreator() - Constructor for class net.sf.asyncobjects.AsyncCreator

AsyncObject - Interface in net.sf.asyncobjects

Base class for all asynchronous interfaces, all operations in subinterfaces are asynchonous.

AsyncProcess<R> - Class in net.sf.asyncobjects.util

This utility class represents a simple asynchronous operation.

AsyncProcess() - Constructor for class net.sf.asyncobjects.util.AsyncProcess

A construct for processs

AsyncProcess.ProcessWhen<I> - Class in net.sf.asyncobjects.util

A utility when variant that fails process (using AsyncProcess.failure(Throwable)) if promise is smashed or body is smashed.

AsyncProcess.ProcessWhen(Promise<I>) - Constructor for class net.sf.asyncobjects.util.AsyncProcess.ProcessWhen

A constructor

AsyncProcess.ProcessWhen(I) - Constructor for class net.sf.asyncobjects.util.AsyncProcess.ProcessWhen

A consctoructor,

AsyncUnicastServer<T extends AsyncObject> - Class in net.sf.asyncobjects

Unicast server implementation.

AsyncUnicastServer() - Constructor for class net.sf.asyncobjects.AsyncUnicastServer

A constructor

ATextChannel - Interface in net.sf.asyncobjects.io

A text channel.

ATextInput - Interface in net.sf.asyncobjects.io

A text input.

ATextOutput - Interface in net.sf.asyncobjects.io

A text output.

ATimer - Interface in net.sf.asyncobjects.util.timer

Timer interface.

ATimerTask - Interface in net.sf.asyncobjects.util.timer

A timer task.

attachmentLock - Variable in class net.sf.asyncobjects.vats.Vat

a lock for detach/attache operations

attachToRunner(VatRunner) - Method in class net.sf.asyncobjects.vats.Vat

Attach to runner

availableForGet() - Method in class net.sf.asyncobjects.io.ByteQueue

avaiable for get

availableForPut() - Method in class net.sf.asyncobjects.io.ByteQueue

availablePermits() - Method in interface net.sf.asyncobjects.util.ASemaphore

This is amount of permits that are released but have not yet been acquired with a ASemaphore.acquire(int) call.

availablePermits() - Method in class net.sf.asyncobjects.util.Semaphore

awake() - Method in class net.sf.asyncobjects.net.nio.NIOStream

awake signal

awake() - Method in class net.sf.asyncobjects.util.RequestQueue

this method awake latest request if there is some need to do so

awaken() - Method in class net.sf.asyncobjects.util.RequestQueue

Sleep until explicitly resumed.

B

BatchedData<D extends BatchedData<D>> - Interface in net.sf.asyncobjects.io

A batched data interface.

beforeClose() - Method in class net.sf.asyncobjects.io.EncoderTextOutput

beforeClose() - Method in class net.sf.asyncobjects.io.util.ExhaustingInput

beforeClose() - Method in class net.sf.asyncobjects.util.CloseableWrapper

Handle close operation

BinaryData - Class in net.sf.asyncobjects.io

Immutable binary data class.

BinaryData.ByteIterator - Class in net.sf.asyncobjects.io

A base class for byte iterators.

BinaryDataBuilder - Class in net.sf.asyncobjects.io

Binary data builder, this is a utility class that could be used to build binary data from datatypes.

BinaryDataBuilder() - Constructor for class net.sf.asyncobjects.io.BinaryDataBuilder

bind(int) - Method in interface net.sf.asyncobjects.net.AServerSocket

Bind to specified port

bind(String, int, int) - Method in interface net.sf.asyncobjects.net.AServerSocket

Bind to specified port an host

bind(int) - Method in class net.sf.asyncobjects.net.nio.NIOServerSocket

Bind socket

bind(String, int, int) - Method in class net.sf.asyncobjects.net.nio.NIOServerSocket

Bind socket

bind(int) - Method in class net.sf.asyncobjects.net.threading.TServerSocket

Bind socket to specific port

bind(String, int, int) - Method in class net.sf.asyncobjects.net.threading.TServerSocket

Bind socket to specific host and port

bodySmashed(Throwable) - Method in class net.sf.asyncobjects.When

This method is called if the method When.resolved(Object) throws exception or when promise returned from that method is smashed.

BoundedByteInput - Class in net.sf.asyncobjects.io.util

Bounded byte input.

BoundedByteInput(AByteInput, boolean, long) - Constructor for class net.sf.asyncobjects.io.util.BoundedByteInput

A constructor

BoundedInput<D extends BatchedData<D>,I extends AInput<D>> - Class in net.sf.asyncobjects.io.util

Input that allows to read at most the specified length.

BoundedInput(I, boolean, long) - Constructor for class net.sf.asyncobjects.io.util.BoundedInput

A constructor

BoundedTextInput - Class in net.sf.asyncobjects.io.util

Bounded Text input.

BoundedTextInput(ATextInput, boolean, long) - Constructor for class net.sf.asyncobjects.io.util.BoundedTextInput

A constructor

BufferedByteChannel - Class in net.sf.asyncobjects.io

Byte channel that wraps existing channel and adds buffering functionality over it.

BufferedByteChannel(AByteChannel, int) - Constructor for class net.sf.asyncobjects.io.BufferedByteChannel

A constructor

BufferedByteInput - Class in net.sf.asyncobjects.io

A buffered byte input stream.

BufferedByteInput(AByteInput, int) - Constructor for class net.sf.asyncobjects.io.BufferedByteInput

A constructor from the stream

BufferedByteOutput - Class in net.sf.asyncobjects.io

Buffered output.

BufferedByteOutput(AByteOutput, int) - Constructor for class net.sf.asyncobjects.io.BufferedByteOutput

A constructor from stream and buffer size

BufferedInput<D extends BatchedData<D>,I extends AInput<D>> - Class in net.sf.asyncobjects.io

A buffered input stream.

BufferedInput(I, int, boolean) - Constructor for class net.sf.asyncobjects.io.BufferedInput

A constructor from the stream

BufferedInput(I, int) - Constructor for class net.sf.asyncobjects.io.BufferedInput

A constructor from the stream

BufferedOutput<D extends BatchedData<D>,O extends AOutput<D>> - Class in net.sf.asyncobjects.io

Buffered output.

BufferedOutput(O, int) - Constructor for class net.sf.asyncobjects.io.BufferedOutput

A constructor from stream and buffer size

BufferedTextChannel - Class in net.sf.asyncobjects.io

Text channel that wraps existing channel and adds buffering functionality over it.

BufferedTextChannel(ATextChannel, int) - Constructor for class net.sf.asyncobjects.io.BufferedTextChannel

A constructor

BufferedTextInput - Class in net.sf.asyncobjects.io

A buffered Text input stream.

BufferedTextInput(ATextInput, int) - Constructor for class net.sf.asyncobjects.io.BufferedTextInput

A constructor from the stream

BufferedTextOutput - Class in net.sf.asyncobjects.io

Buffered output.

BufferedTextOutput(ATextOutput, int) - Constructor for class net.sf.asyncobjects.io.BufferedTextOutput

A constructor from stream and buffer size

BufferProvider - Interface in net.sf.asyncobjects.io

A provider for NIO buffers.

bufferSize - Variable in class net.sf.asyncobjects.io.BufferedByteChannel

a buffer size

bufferSize - Variable in class net.sf.asyncobjects.io.BufferedTextChannel

a buffer size

byteAt(int) - Method in class net.sf.asyncobjects.io.BinaryData

Byte at specified position

BytePipe - Class in net.sf.asyncobjects.io

A pipe is pair of output stream and input stream, what is written to output stream, could be later read from input stream.

BytePipe(int) - Constructor for class net.sf.asyncobjects.io.BytePipe

make a pipe

BytePipe.InternalBytePipeInput - Class in net.sf.asyncobjects.io

Pipe input

BytePipe.InternalBytePipeOutput - Class in net.sf.asyncobjects.io

Pipe output

ByteQueue - Class in net.sf.asyncobjects.io

actually JDK 1.4 buffer should be used instead of this one, but there is an intention to make sources compatible with 1.3 and personal profile platform.

ByteQueue(int) - Constructor for class net.sf.asyncobjects.io.ByteQueue

size of buffer

ByteStreamForwarder - Class in net.sf.asyncobjects.io

Deprecated. IOUtils.forward(AInput, AOutput, long, int)

ByteStreamForwarder(AByteInput, AByteOutput, int, boolean) - Constructor for class net.sf.asyncobjects.io.ByteStreamForwarder

Deprecated. a consturtor

C

call() - Method in interface net.sf.asyncobjects.util.callbacks.ACallable

call() - Method in class net.sf.asyncobjects.util.callbacks.CallableAdapter

Call the action

call() - Method in class net.sf.asyncobjects.util.callbacks.CallableAdapter.InternalCallableAdapter

CallableAdapter<T> - Class in net.sf.asyncobjects.util.callbacks

This is an adapter for callable actions that allows to create ACallable instances using anonymous inner classes.

CallableAdapter() - Constructor for class net.sf.asyncobjects.util.callbacks.CallableAdapter

CallableAdapter.InternalCallableAdapter - Class in net.sf.asyncobjects.util.callbacks

An internal class that addapt Adapter calss to asynchronous interface.

cancel() - Method in class net.sf.asyncobjects.util.Compensated

Cancel computation if it is possible.

cancel() - Method in class net.sf.asyncobjects.util.timer.TimerTaskAdapter

Cancel task.

cancelledEqueuedVat(Vat, Object) - Method in class net.sf.asyncobjects.vats.VatRunner

This method cancels enquued vat and detaches it from runner.

capacity() - Method in class net.sf.asyncobjects.io.ByteQueue

cast(Class<O>) - Method in class net.sf.asyncobjects.Promise

Cast promise to another type.

charAt(int) - Method in class net.sf.asyncobjects.io.TextData

checkNext() - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

Subclass call this method to ensure that it is possible to advance further.

clear() - Method in class net.sf.asyncobjects.io.ByteQueue

clear queue from all elements

close() - Method in interface net.sf.asyncobjects.ACloseable

Close resource

close() - Method in class net.sf.asyncobjects.io.adapters.InputStreamAdapter

close stream

close() - Method in class net.sf.asyncobjects.io.adapters.OutputStreamAdapter

close stream

close() - Method in class net.sf.asyncobjects.io.BufferedInput

close stream

close() - Method in class net.sf.asyncobjects.io.BufferedOutput

register close request and possibly execute it.

close() - Method in class net.sf.asyncobjects.io.Pipe

Channel close

close() - Method in class net.sf.asyncobjects.io.Pipe.InternalPipeInput

close stream

close() - Method in class net.sf.asyncobjects.io.Pipe.InternalPipeOutput

close stream

close() - Method in class net.sf.asyncobjects.io.util.GeneratingInput

close() - Method in class net.sf.asyncobjects.io.util.MulticastOutput

Close stream

close() - Method in class net.sf.asyncobjects.io.util.NulInput

close() - Method in class net.sf.asyncobjects.io.util.RecordingOutput

close() - Method in class net.sf.asyncobjects.io.WrappingChannel

close() - Method in class net.sf.asyncobjects.net.nio.NIOServerSocket

Perform close operation

close() - Method in class net.sf.asyncobjects.net.nio.NIOSocket

close the socket

close() - Method in class net.sf.asyncobjects.net.nio.NIOStream

Close stream

close() - Method in class net.sf.asyncobjects.net.threading.TServerSocket

Close socket

close() - Method in class net.sf.asyncobjects.net.threading.TSocket

close() - Method in class net.sf.asyncobjects.net.threading.TSocket.TInputStreamAdapter

close() - Method in class net.sf.asyncobjects.net.threading.TSocket.TOutputStreamAdapter

close() - Method in class net.sf.asyncobjects.util.CloseableWrapper

close() - Method in class net.sf.asyncobjects.util.timer.TimerWrapper

CloseableWrapper<FacetType extends ACloseable,WrappedType extends ACloseable> - Class in net.sf.asyncobjects.util

This is a base class for closeables that built upon other closeable objects.

CloseableWrapper(WrappedType, boolean) - Constructor for class net.sf.asyncobjects.util.CloseableWrapper

A constructor

CloseableWrapper.InvalidatingWhen<I,R> - Class in net.sf.asyncobjects.util

When that invalidates the stream in case of exception

CloseableWrapper.InvalidatingWhen(Promise<I>) - Constructor for class net.sf.asyncobjects.util.CloseableWrapper.InvalidatingWhen

A constructor from superclass

closed() - Method in class net.sf.asyncobjects.util.CloseableWrapper

closeWrapper - Variable in class net.sf.asyncobjects.util.CloseableWrapper

if true, inner stream should be closed

committed() - Method in class net.sf.asyncobjects.util.Compensated

Commit computation.

compare(AInput<D>, AInput<D>, int) - Static method in class net.sf.asyncobjects.io.IOUtils

Compare inputs.

compareTo(BinaryData) - Method in class net.sf.asyncobjects.io.BinaryData

Compare an object to another binary data

compareTo(TextData) - Method in class net.sf.asyncobjects.io.TextData

Compare text data

Compensated - Class in net.sf.asyncobjects.util

This a special return value for actions in some control constructs like Any.

Compensated() - Constructor for class net.sf.asyncobjects.util.Compensated

CompensatedClosable - Class in net.sf.asyncobjects.util

An utility subclass that closes closable that has been received.

CompensatedClosable() - Constructor for class net.sf.asyncobjects.util.CompensatedClosable

compensateFailure(Throwable) - Method in class net.sf.asyncobjects.util.Compensated

Compensate failed execution.

compensateValue(Object) - Method in class net.sf.asyncobjects.util.Compensated

Compensate successful execution

compensateValue(Object) - Method in class net.sf.asyncobjects.util.CompensatedClosable

concat(D) - Method in interface net.sf.asyncobjects.io.BatchedData

Concatenage two items

concat(BinaryData[]) - Static method in class net.sf.asyncobjects.io.BinaryData

Concatenate binary data into large binary data

concat(BinaryData) - Method in class net.sf.asyncobjects.io.BinaryData

Concatenate

concat(TextData...) - Static method in class net.sf.asyncobjects.io.TextData

Concatenate text data

concat(TextData) - Method in class net.sf.asyncobjects.io.TextData

Concatenate

Condition - Class in net.sf.asyncobjects.util

This class implements some logical conditions.

Condition() - Constructor for class net.sf.asyncobjects.util.Condition

connect(String, int) - Method in interface net.sf.asyncobjects.net.ASocket

Connect socket to specified port and host

connect(String, int) - Method in class net.sf.asyncobjects.net.nio.NIOSocket

A connecto operation

connect(String, int) - Method in class net.sf.asyncobjects.net.threading.TSocket

Connect to specific host and port

create() - Method in class net.sf.asyncobjects.AsyncCreator

This method should be overriden in subclasses to create an asynchronous object in other vat.

createInOtherVat(Vat, Class<R>) - Method in class net.sf.asyncobjects.AsyncCreator

Create object in other vat.

createInput() - Method in class net.sf.asyncobjects.io.BytePipe

createInput() - Method in class net.sf.asyncobjects.io.Pipe

createInput() - Method in class net.sf.asyncobjects.io.TextPipe

createOutput() - Method in class net.sf.asyncobjects.io.BytePipe

createOutput() - Method in class net.sf.asyncobjects.io.Pipe

createOutput() - Method in class net.sf.asyncobjects.io.TextPipe

current - Variable in class net.sf.asyncobjects.io.BinaryData.ByteIterator

current position

current() - Static method in class net.sf.asyncobjects.vats.Vat

Current vat for current thread.

D

dataPromise() - Method in class net.sf.asyncobjects.io.util.RecordingOutput

DecoderTextInput - Class in net.sf.asyncobjects.io

A text input that uses CharsetDecoder to convert byte input to character input.

DecoderTextInput(BufferProvider, AByteInput, boolean, CharsetDecoder, int) - Constructor for class net.sf.asyncobjects.io.DecoderTextInput

A constructor

DecoderTextInput(String, AByteInput) - Constructor for class net.sf.asyncobjects.io.DecoderTextInput

A constructor

DefaultBufferProvider - Class in net.sf.asyncobjects.io

A default buffer provider.

DefaultBufferProvider(int, int) - Constructor for class net.sf.asyncobjects.io.DefaultBufferProvider

A default constructor

delayFor(ATimer, long, T) - Static method in class net.sf.asyncobjects.util.timer.TimerUtils

Delay returning value until spefied time

delayFor(ATimer, long, Promise<T>) - Static method in class net.sf.asyncobjects.util.timer.TimerUtils

Delay returning value until spefied time

delayUntil(ATimer, Date, T) - Static method in class net.sf.asyncobjects.util.timer.TimerUtils

Delay returning value until spefied time

delayUntil(ATimer, Date, Promise<T>) - Static method in class net.sf.asyncobjects.util.timer.TimerUtils

Delay returning value until spefied time

dereference(AResolver<?>) - Method in interface net.sf.asyncobjects.AsyncObject

adds listener for this object if it is promise reference this method exists for when constuct.

dereference(AResolver<?>) - Method in class net.sf.asyncobjects.AsyncUnicastServer

Implementation of dereference method.

dereference(AResolver<? super T>) - Method in class net.sf.asyncobjects.Promise

Register resolver for the promise.

detach - Variable in class net.sf.asyncobjects.vats.Vat

a semaphore for detach process, guared by state lock

detachFromRunner(boolean) - Method in class net.sf.asyncobjects.net.nio.NIOSelectorVat

detachFromRunner(boolean) - Method in class net.sf.asyncobjects.vats.Vat

Detach from runner.

discard(AInput<D>, long, int) - Static method in class net.sf.asyncobjects.io.IOUtils

Discard specified amount of elements from input.

dispatchEventBatch(int) - Method in class net.sf.asyncobjects.vats.Vat

Dispatch events without setting context

dispatchVatEvents(Object, int) - Method in class net.sf.asyncobjects.vats.Vat

Dispatch at most n events for the vat.

doInCurrentThread() - Method in class net.sf.asyncobjects.AsyncAction

Execute this action in the current thread.

doInCurrentThread(ThreadBasedRunner) - Method in class net.sf.asyncobjects.AsyncAction

Execute this action in the current thread.

doInOtherVat(Vat) - Method in class net.sf.asyncobjects.AsyncAction

Execute action in context of other vat.

drainPermits() - Method in interface net.sf.asyncobjects.util.ASemaphore

Drain all available permits.

drainPermits() - Method in class net.sf.asyncobjects.util.Semaphore

drop(int) - Method in interface net.sf.asyncobjects.io.BatchedData

Get new data with first n elements dropped

drop(int) - Method in class net.sf.asyncobjects.io.BinaryData

drop(int) - Method in class net.sf.asyncobjects.io.TextData

dropTo(int, byte[], int) - Method in class net.sf.asyncobjects.io.BinaryData

Copy data to array and drop copied data.

E

empty() - Static method in class net.sf.asyncobjects.io.BinaryData

EMPTY - Static variable in class net.sf.asyncobjects.io.TextData

empty text data

empty() - Static method in class net.sf.asyncobjects.io.TextData

EncoderTextOutput - Class in net.sf.asyncobjects.io

An output that encodes the text into binary.

EncoderTextOutput(String, AByteOutput) - Constructor for class net.sf.asyncobjects.io.EncoderTextOutput

A constructor

EncoderTextOutput(CharsetEncoder, AByteOutput, boolean) - Constructor for class net.sf.asyncobjects.io.EncoderTextOutput

A constructor

EncoderTextOutput(BufferProvider, CharsetEncoder, AByteOutput, boolean) - Constructor for class net.sf.asyncobjects.io.EncoderTextOutput

A constructor

endRequest() - Method in class net.sf.asyncobjects.util.RequestQueue

End current required

endsWith(BinaryData) - Method in class net.sf.asyncobjects.io.BinaryData

Check if one binary data ends with another

enqueue(Runnable) - Method in class net.sf.asyncobjects.vats.Vat

enqueue runnuable

ensureOpen() - Method in class net.sf.asyncobjects.net.nio.NIOStream

Ensure that stream is open

ensureOpen() - Method in class net.sf.asyncobjects.util.CloseableWrapper

Ensure that stream is open

ensureSharable(Object) - Static method in class net.sf.asyncobjects.Promise

Ensure that value is sharable

ensureValid() - Method in class net.sf.asyncobjects.util.CloseableWrapper

Ensure that stream is valid.

equals(Object) - Method in class net.sf.asyncobjects.io.BinaryData

equals(Object) - Method in class net.sf.asyncobjects.io.TextData

equals(Object) - Method in class net.sf.asyncobjects.util.Compensated

executeLater() - Method in class net.sf.asyncobjects.AsyncAction

Execute action in current vat.

executeNow() - Method in class net.sf.asyncobjects.AsyncAction

Execute action in current vat.

executeNow(AResolver<? super T>) - Method in class net.sf.asyncobjects.AsyncAction

Execute action in current vat.

ExecutorRunner - Class in net.sf.asyncobjects.vats

This runner is being run over some Executor service.

ExecutorRunner(Executor) - Constructor for class net.sf.asyncobjects.vats.ExecutorRunner

A constructor of executor

exhausted() - Method in class net.sf.asyncobjects.io.util.ExhaustingInput

ExhaustingByteInput - Class in net.sf.asyncobjects.io.util

Byte version of ExhaustingInput.

ExhaustingByteInput(AByteInput, boolean) - Constructor for class net.sf.asyncobjects.io.util.ExhaustingByteInput

A constructor

ExhaustingInput<D extends BatchedData<D>,I extends AInput<D>> - Class in net.sf.asyncobjects.io.util

This input waits until stream is fully readed.

ExhaustingInput(D, I, boolean) - Constructor for class net.sf.asyncobjects.io.util.ExhaustingInput

A construcor

ExhaustingTextInput - Class in net.sf.asyncobjects.io.util

Text version of ExhaustingInput.

ExhaustingTextInput(ATextInput, boolean) - Constructor for class net.sf.asyncobjects.io.util.ExhaustingTextInput

A constructor

Experimental - Annotation Type in net.sf.asyncobjects.util

This annotation means that annotated element is an experimental feature and it might wanish in the next versions without any notice.

ExplicitSharing - Interface in net.sf.asyncobjects

This marker interface marks objects that should be always shared explicitiyly wrapped into Shared object.

export() - Method in class net.sf.asyncobjects.AsyncUnicastServer

export() - Method in class net.sf.asyncobjects.util.callbacks.CallableAdapter

export() - Method in class net.sf.asyncobjects.util.callbacks.ListenerAdapter

export() - Method in class net.sf.asyncobjects.util.callbacks.MapperAdapter

export() - Method in class net.sf.asyncobjects.util.callbacks.RunnableAdapter

export() - Method in class net.sf.asyncobjects.util.timer.TimerTaskAdapter

F

failure(Throwable) - Method in class net.sf.asyncobjects.util.AsyncProcess

Subclasses should call this method to indicate that process failed.

falsePromise() - Static method in class net.sf.asyncobjects.util.Condition

finallyDo() - Method in class net.sf.asyncobjects.util.All

This callback is executed after all action finished and before result is returned.

finallyDo() - Method in class net.sf.asyncobjects.util.Any

This callback is executed after first action is finshed and before result is returned returned.

finallyDo() - Method in class net.sf.asyncobjects.util.Seq

This method is executed when all actions are finished.

finallyDo() - Method in class net.sf.asyncobjects.When

This action is called when promise is already either resolved or smashed if this method returns promise, the result promise is not resolved until a promise returned by this method is resolved.

finished() - Method in class net.sf.asyncobjects.Promise

finished(Promise<?>) - Static method in class net.sf.asyncobjects.Promise

flatten() - Method in class net.sf.asyncobjects.io.BinaryData

Defragment the node and ensure that it uses minimal amound of allocated data.

flatten() - Method in class net.sf.asyncobjects.io.TextData

flush() - Method in class net.sf.asyncobjects.io.adapters.OutputStreamAdapter

Flush output

flush() - Method in interface net.sf.asyncobjects.io.AOutput

Flush data in stream, upon return of this method all data will be written out to most underlying layer

flush() - Method in class net.sf.asyncobjects.io.BufferedOutput

flush() - Method in class net.sf.asyncobjects.io.EncoderTextOutput

flush() - Method in class net.sf.asyncobjects.io.Pipe.InternalPipeOutput

Flush output

flush() - Method in class net.sf.asyncobjects.io.util.MulticastOutput

Flush data

flush() - Method in class net.sf.asyncobjects.io.util.RecordingOutput

flush() - Method in class net.sf.asyncobjects.net.nio.NIOSocketOutputStream

Flush stream.

forceClose() - Method in class net.sf.asyncobjects.util.timer.TimerWrapper

This method is intentionally not exported on the asynchronous facet interface.

forward(AInput<D>, AOutput<D>, long, int) - Static method in class net.sf.asyncobjects.io.IOUtils

Forward data from input to output

forward(AInput<D>, AOutput<D>, long, int, boolean) - Static method in class net.sf.asyncobjects.io.IOUtils

Forward data from input to output

fromBytes(byte...) - Static method in class net.sf.asyncobjects.io.BinaryData

Get binary data wrapper from specified byte array

fromBytes(byte[], int, int) - Static method in class net.sf.asyncobjects.io.BinaryData

Get binary data wrapper from specified byte array

fromStrings(String...) - Static method in class net.sf.asyncobjects.io.TextData

Create text data from sequence of strings

G

generate(int) - Method in class net.sf.asyncobjects.io.util.GeneratingInput

Generate at most limit of the data

generate(int) - Method in class net.sf.asyncobjects.io.util.RandomByteInput

generate(int) - Method in class net.sf.asyncobjects.io.util.RandomTextInput

generate(int) - Method in class net.sf.asyncobjects.io.util.RepeatingInput

generated() - Method in class net.sf.asyncobjects.io.util.GeneratingInput

generateVatName(Class<?>) - Static method in class net.sf.asyncobjects.vats.Vat

Generate vat name

GeneratingInput<D extends BatchedData<D>,I extends AInput<D>> - Class in net.sf.asyncobjects.io.util

A input that generates some data.

GeneratingInput() - Constructor for class net.sf.asyncobjects.io.util.GeneratingInput

A consructor

GeneratingInput(long) - Constructor for class net.sf.asyncobjects.io.util.GeneratingInput

A consructor

get(ByteBuffer) - Static method in class net.sf.asyncobjects.io.BinaryData

Get data from NIO buffer.

get(byte[]) - Method in class net.sf.asyncobjects.io.ByteQueue

Get bytes into array

get(byte[], int, int) - Method in class net.sf.asyncobjects.io.ByteQueue

Get bytes into array

get(CharBuffer) - Static method in class net.sf.asyncobjects.io.TextData

Get text data from character buffer

get() - Method in interface net.sf.asyncobjects.util.AQueue

Get object from the queue

get() - Method in class net.sf.asyncobjects.util.Queue

getBachingFactor() - Method in class net.sf.asyncobjects.vats.VatRunner

getByteBuffer() - Method in interface net.sf.asyncobjects.io.BufferProvider

getByteBuffer() - Method in class net.sf.asyncobjects.io.DefaultBufferProvider

getCharBuffer() - Method in interface net.sf.asyncobjects.io.BufferProvider

getCharBuffer() - Method in class net.sf.asyncobjects.io.DefaultBufferProvider

getCurrentVat() - Method in interface net.sf.asyncobjects.vats.VatSensor

getDirectBuffer() - Method in class net.sf.asyncobjects.net.nio.NIOSelectorRunner

getDirectBuffer() - Method in class net.sf.asyncobjects.net.nio.NIOStream

getErr() - Static method in class net.sf.asyncobjects.io.adapters.Adapters

getFailures() - Method in exception net.sf.asyncobjects.util.WaitAllException

getIn() - Static method in class net.sf.asyncobjects.io.adapters.Adapters

getInput() - Method in interface net.sf.asyncobjects.io.AChannel

getInput() - Method in class net.sf.asyncobjects.io.Pipe

getInput() - Method in class net.sf.asyncobjects.io.WrappingChannel

getInput() - Method in class net.sf.asyncobjects.net.nio.NIOSocket

getInput() - Method in class net.sf.asyncobjects.net.threading.TSocket

getInstance(VatRunner) - Static method in class net.sf.asyncobjects.net.threading.TSocketFactory

This method created instance of TSocketFactory that lives inside specified vatGroup

getInstance() - Static method in class net.sf.asyncobjects.net.threading.TSocketFactory

This method created instance of TSocketFactory that lives inside daemon runner created with ExecutorRunner.newCachedRunner(String, Boolean).

getName() - Method in class net.sf.asyncobjects.vats.Vat

get vat name

getOut() - Static method in class net.sf.asyncobjects.io.adapters.Adapters

getOutput() - Method in interface net.sf.asyncobjects.io.AChannel

getOutput() - Method in class net.sf.asyncobjects.io.Pipe

getOutput() - Method in class net.sf.asyncobjects.io.WrappingChannel

getOutput() - Method in class net.sf.asyncobjects.net.nio.NIOSocket

getOutput() - Method in class net.sf.asyncobjects.net.threading.TSocket

getPartialResults() - Method in exception net.sf.asyncobjects.util.WaitAllException

getRunner() - Method in class net.sf.asyncobjects.vats.Vat

getState() - Method in class net.sf.asyncobjects.vats.VatRunner

getTcpNoDelay() - Method in interface net.sf.asyncobjects.net.ASocket

Get value of TCP_NODELAY option

getTcpNoDelay() - Method in class net.sf.asyncobjects.net.nio.NIOSocket

Set TCP_NODELAY option

getTcpNoDelay() - Method in class net.sf.asyncobjects.net.threading.TSocket

Get TCP_NODELAY

getThreadFactory(ThreadFactory, String, Boolean) - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Get thread factory

H

hasEvents(Vat, Object) - Method in class net.sf.asyncobjects.vats.ExecutorRunner

hasEvents(Vat, Object) - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

hasEvents() - Method in class net.sf.asyncobjects.vats.Vat

hasEvents(Vat, Object) - Method in class net.sf.asyncobjects.vats.VatQueueRunner

hasEvents(Vat, Object) - Method in class net.sf.asyncobjects.vats.VatRunner

This method is called by the vat when new events have arrived.

hashCode() - Method in class net.sf.asyncobjects.io.BinaryData

hashCode() - Method in class net.sf.asyncobjects.io.TextData

Implemetned like String.hashCode()

hashCode() - Method in class net.sf.asyncobjects.util.Compensated

hasNext() - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

head(int) - Method in interface net.sf.asyncobjects.io.BatchedData

Get data with first n elements

head(int) - Method in class net.sf.asyncobjects.io.BinaryData

head(int) - Method in class net.sf.asyncobjects.io.TextData

I

idle() - Method in class net.sf.asyncobjects.net.nio.NIOSelectorRunner

perform idle action, idle action should stop to be performed after wakeup call.

idle() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

perform idle action, idle action should stop to be performed after wakeup call.

in - Variable in class net.sf.asyncobjects.io.WrappingChannel

an input

init() - Method in class net.sf.asyncobjects.net.nio.NIOSelectorRunner

init action

init() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

Init the vat

InputStreamAdapter - Class in net.sf.asyncobjects.io.adapters

Adapter for input stream

InputStreamAdapter(InputStream) - Constructor for class net.sf.asyncobjects.io.adapters.InputStreamAdapter

A constructor

InputStreamAdapter(InputStream, int) - Constructor for class net.sf.asyncobjects.io.adapters.InputStreamAdapter

A constructor

intAt(int) - Method in class net.sf.asyncobjects.io.BinaryData

Get big endian int at the specified posion.

invalidate(Throwable) - Method in class net.sf.asyncobjects.util.CloseableWrapper

Invalidate the closeable

InvalidMethodException - Exception in net.sf.asyncobjects

This exception is thrown from proxies on methods that are not valid asynchronous methods or if implementation of this method is missed.

InvalidMethodException(String) - Constructor for exception net.sf.asyncobjects.InvalidMethodException

A constructor from superclass

IOUtils - Class in net.sf.asyncobjects.io

IO Utilties

IOUtils() - Constructor for class net.sf.asyncobjects.io.IOUtils

isClosed - Variable in class net.sf.asyncobjects.net.nio.NIOStream

if true the stream is considered to be closed

isDetached() - Method in class net.sf.asyncobjects.vats.Vat

isEmpty() - Method in interface net.sf.asyncobjects.io.BatchedData

isEmpty() - Method in class net.sf.asyncobjects.io.BinaryData

isEmpty() - Method in class net.sf.asyncobjects.io.ByteQueue

isEmpty() - Method in class net.sf.asyncobjects.io.TextData

isFull() - Method in class net.sf.asyncobjects.io.ByteQueue

isIdle - Variable in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

if true, the action is currently idle

isImmediate() - Method in interface net.sf.asyncobjects.AsyncObject

isImmediate() - Method in class net.sf.asyncobjects.AsyncUnicastServer

isPushbackSupported() - Method in class net.sf.asyncobjects.io.adapters.InputStreamAdapter

isPushbackSupported() - Method in interface net.sf.asyncobjects.io.AInput

isPushbackSupported() - Method in class net.sf.asyncobjects.io.BufferedInput

isPushbackSupported() - Method in class net.sf.asyncobjects.io.DecoderTextInput

isPushbackSupported() - Method in class net.sf.asyncobjects.io.Pipe.InternalPipeInput

isPushbackSupported() - Method in class net.sf.asyncobjects.io.util.BoundedInput

isPushbackSupported() - Method in class net.sf.asyncobjects.io.util.ExhaustingInput

isPushbackSupported() - Method in class net.sf.asyncobjects.io.util.GeneratingInput

isPushbackSupported() - Method in class net.sf.asyncobjects.io.util.NulInput

isPushbackSupported() - Method in class net.sf.asyncobjects.io.util.SavingInput

isPushbackSupported() - Method in class net.sf.asyncobjects.io.util.UncloseableInput

isPushbackSupported() - Method in class net.sf.asyncobjects.net.nio.NIOSocketInputStream

isResolved() - Method in class net.sf.asyncobjects.Promise

isSmashed() - Method in class net.sf.asyncobjects.Promise

isStopping() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

isUnresolved() - Method in class net.sf.asyncobjects.Promise

isValid() - Method in class net.sf.asyncobjects.util.CloseableWrapper

isValidPosition(int) - Method in class net.sf.asyncobjects.io.BinaryData

Check if position is a vaild one

isValidRange(int, int) - Method in class net.sf.asyncobjects.io.BinaryData

Check if range is completly within this object

iterator(int, int) - Method in class net.sf.asyncobjects.io.BinaryData

Get iterator.

iterator() - Method in class net.sf.asyncobjects.io.BinaryData

iterator() - Method in class net.sf.asyncobjects.io.TextData

L

length() - Method in interface net.sf.asyncobjects.io.BatchedData

length() - Method in class net.sf.asyncobjects.io.BinaryData

length() - Method in class net.sf.asyncobjects.io.TextData

limit - Variable in class net.sf.asyncobjects.io.BinaryData.ByteIterator

current position

ListenerAdapter<Event> - Class in net.sf.asyncobjects.util.callbacks

An adapter for listeners class

ListenerAdapter() - Constructor for class net.sf.asyncobjects.util.callbacks.ListenerAdapter

ListenerAdapter.InternalListenerAdapter - Class in net.sf.asyncobjects.util.callbacks

An internal class that addapt Adapter calss to asynchronous interface.

logDebugOutcome(Logger, String, Promise<?>) - Static method in class net.sf.asyncobjects.util.LogUtils

Log outcome of promised operation

logInfoOutcome(Logger, String, Promise<?>) - Static method in class net.sf.asyncobjects.util.LogUtils

Log outcome of promised operation

logOutcome(Logger, Level, String, Promise<?>) - Static method in class net.sf.asyncobjects.util.LogUtils

Log outcome of promised operation

LogUtils - Class in net.sf.asyncobjects.util

Utilities that help to log events related to the framework.

LogUtils() - Constructor for class net.sf.asyncobjects.util.LogUtils

longAt(int) - Method in class net.sf.asyncobjects.io.BinaryData

Get big endian long at the specified posion.

M

makeServerSocket() - Method in interface net.sf.asyncobjects.net.ASocketFactory

makeServerSocket() - Method in class net.sf.asyncobjects.net.nio.NIOSocketFactory

makeServerSocket() - Method in class net.sf.asyncobjects.net.threading.TSocketFactory

makeSocket() - Method in interface net.sf.asyncobjects.net.ASocketFactory

makeSocket() - Method in class net.sf.asyncobjects.net.nio.NIOSocketFactory

makeSocket() - Method in class net.sf.asyncobjects.net.threading.TSocketFactory

map(I) - Method in interface net.sf.asyncobjects.util.callbacks.AMapper

Map a value

map(I) - Method in class net.sf.asyncobjects.util.callbacks.MapperAdapter.InternalMapperAdapter

map(I) - Method in class net.sf.asyncobjects.util.callbacks.MapperAdapter

A map function

MapperAdapter<I,O> - Class in net.sf.asyncobjects.util.callbacks

Adapter for the AMapper interface.

MapperAdapter() - Constructor for class net.sf.asyncobjects.util.callbacks.MapperAdapter

MapperAdapter.InternalMapperAdapter - Class in net.sf.asyncobjects.util.callbacks

An internal class that addapt Adapter calss to asynchronous interface.

MulticastByteOutput - Class in net.sf.asyncobjects.io.util

Byte version of MulticastOutput

MulticastByteOutput(AByteOutput...) - Constructor for class net.sf.asyncobjects.io.util.MulticastByteOutput

A constructor

MulticastOutput<D extends BatchedData<D>,O extends AOutput<D>> - Class in net.sf.asyncobjects.io.util

A stream that copies data written to it into streams passed to it as arguments.

MulticastOutput(O...) - Constructor for class net.sf.asyncobjects.io.util.MulticastOutput

A constructor

MulticastTextOutput - Class in net.sf.asyncobjects.io.util

Text version of MulticastOutput

MulticastTextOutput(ATextOutput...) - Constructor for class net.sf.asyncobjects.io.util.MulticastTextOutput

A constructor

myVat() - Method in class net.sf.asyncobjects.AsyncUnicastServer

N

net.sf.asyncobjects - package net.sf.asyncobjects

The core classes of the framework.

net.sf.asyncobjects.io - package net.sf.asyncobjects.io

This package contains core IO interfaces.

net.sf.asyncobjects.io.adapters - package net.sf.asyncobjects.io.adapters

This package contains adapters to blocking java streams.

net.sf.asyncobjects.io.util - package net.sf.asyncobjects.io.util

This package contains uitility input and output streams.

net.sf.asyncobjects.net - package net.sf.asyncobjects.net

This package contains core network interfaces.

net.sf.asyncobjects.net.nio - package 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 - package net.sf.asyncobjects.net.threading

This package contains implementation of network interfaces that is based on blocking socket API.

net.sf.asyncobjects.util - package net.sf.asyncobjects.util

This package contains generic utilities that helps to develop asynchronous operations.

net.sf.asyncobjects.util.callbacks - package net.sf.asyncobjects.util.callbacks

This package contains a generic callbacks interfaces and adapter classes that help to implement them.

net.sf.asyncobjects.util.timer - package net.sf.asyncobjects.util.timer

This package contains generic timer interfaces and implementation of them over Timer nad TimerTask classes.

net.sf.asyncobjects.vats - package net.sf.asyncobjects.vats

This package contains core classes releate to vats and vat runners.

newCachedRunner(ThreadFactory) - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Creates new runner over executor created by Executors.newCachedThreadPool(ThreadFactory).

newCachedRunner() - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Creates new runner over executor created by Executors.newCachedThreadPool().

newCachedRunner(ThreadFactory, String, Boolean) - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Creates new runner over executor created by Executors.newCachedThreadPool(ThreadFactory).

newCachedRunner(String, Boolean) - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Creates new runner over executor created by Executors.newCachedThreadPool(ThreadFactory).

newCachedRunner(String) - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Creates new runner over executor created by Executors.newCachedThreadPool(ThreadFactory).

newFixedThreadPoolRunner(int, ThreadFactory, String, Boolean) - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Creates new runner over fixed size thread pool

newFixedThreadPoolRunner(int, String, Boolean) - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Creates new runner over fixed size thread pool

newFixedThreadPoolRunner(int, Boolean) - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Creates new runner over fixed size thread pool

newFixedThreadPoolRunner(int, String) - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Creates new runner over fixed size thread pool

newFixedThreadPoolRunner(int) - Static method in class net.sf.asyncobjects.vats.ExecutorRunner

Creates new runner over fixed size thread pool

newVat(String) - Method in class net.sf.asyncobjects.net.nio.NIOSelectorRunner

newVat(String) - Method in interface net.sf.asyncobjects.vats.VatFactory

Create default vat for this runner

newVat() - Method in interface net.sf.asyncobjects.vats.VatFactory

Create default vat for this runner.

newVat(String) - Method in class net.sf.asyncobjects.vats.VatRunner

Create default vat for this runner

newVat() - Method in class net.sf.asyncobjects.vats.VatRunner

Create default vat for this runner.

next() - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

nextArray(byte[], int, int) - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

Copy data to array

nextByte() - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

nextInt() - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

Get next big endian int.

nextLong() - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

Get next big endian long.

nextShort() - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

Get big endian short at the specified posion.

nextSubrange(int) - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

Next subrange

NIOSelectorRunner - Class in net.sf.asyncobjects.net.nio

A selector runner, there could be only one vat per selector and only one selector in runner.

NIOSelectorRunner(String, boolean) - Constructor for class net.sf.asyncobjects.net.nio.NIOSelectorRunner

A constructor

NIOSelectorRunner() - Constructor for class net.sf.asyncobjects.net.nio.NIOSelectorRunner

a constructor

NIOSelectorVat - Class in net.sf.asyncobjects.net.nio

This is a vat that uses NIO services provided by NIOSelectorRunner.

NIOSelectorVat(NIOSelectorRunner, String) - Constructor for class net.sf.asyncobjects.net.nio.NIOSelectorVat

A constructor

NIOServerSocket - Class in net.sf.asyncobjects.net.nio

Implementation of server sockets based on nio.

NIOSocket - Class in net.sf.asyncobjects.net.nio

NIO-based implementation of socket

NIOSocketFactory - Class in net.sf.asyncobjects.net.nio

NIO socket factory, this factory could be created only in context of NIO selector vat.

NIOSocketFactory() - Constructor for class net.sf.asyncobjects.net.nio.NIOSocketFactory

a constructor

NIOSocketInputStream - Class in net.sf.asyncobjects.net.nio

implementation of stream for sockets

NIOSocketOutputStream - Class in net.sf.asyncobjects.net.nio

Output stream based on SocketChannel.

NIOStream<T extends ACloseable> - Class in net.sf.asyncobjects.net.nio

Base class for NIO Streams.

NO_FURTHER_ACTIONS - Static variable in class net.sf.asyncobjects.util.RunDispatcher

This is a special return value indicating that no action should be taken

not(Promise<Boolean>) - Static method in class net.sf.asyncobjects.util.Condition

Logical not operation.

notNull(Promise<? extends O>) - Static method in class net.sf.asyncobjects.Promise

Return promise that never returns null.

notNull(Promise<? extends O>, String) - Static method in class net.sf.asyncobjects.Promise

Return promise that never returns null.

NulByteInput - Class in net.sf.asyncobjects.io.util

A nul byte input.

NulByteInput() - Constructor for class net.sf.asyncobjects.io.util.NulByteInput

NulInput<D extends BatchedData<D>,I extends AInput<D>> - Class in net.sf.asyncobjects.io.util

A zero lenght stream.

NulInput() - Constructor for class net.sf.asyncobjects.io.util.NulInput

nullPromise() - Static method in class net.sf.asyncobjects.Promise

Return a promise resolved to null.

NulTextInput - Class in net.sf.asyncobjects.io.util

A nul text input.

NulTextInput() - Constructor for class net.sf.asyncobjects.io.util.NulTextInput

O

offerSensor(Class) - Static method in class net.sf.asyncobjects.vats.Vat

Offer sensor to vat

onEvent(Event) - Method in interface net.sf.asyncobjects.util.callbacks.AListener

This callback is invoked when specifie event happens.

onEvent(Event) - Method in class net.sf.asyncobjects.util.callbacks.ListenerAdapter.InternalListenerAdapter

onEvent(Event) - Method in class net.sf.asyncobjects.util.callbacks.ListenerAdapter

This callback is invoked when specifie event happens.

onFailure(Throwable) - Method in class net.sf.asyncobjects.util.AsyncProcess

This method is called when process completed unsuccessfully.

onMalformedInput(CodingErrorAction) - Method in class net.sf.asyncobjects.io.DecoderTextInput

Configure decoder to execute specifed action on malformed input

onMalformedInput(CodingErrorAction) - Method in class net.sf.asyncobjects.io.EncoderTextOutput

Configure encoder to execute specifed action on malformed input

onSuccess(R) - Method in class net.sf.asyncobjects.util.AsyncProcess

This method is called when process completed successfully.

onUnmappableCharacter(CodingErrorAction) - Method in class net.sf.asyncobjects.io.DecoderTextInput

Configure decoder to execute specifed action on unmappable character

onUnmappableCharacter(CodingErrorAction) - Method in class net.sf.asyncobjects.io.EncoderTextOutput

Configure encoder to execute specifed action on unmappable character

open() - Method in class net.sf.asyncobjects.util.CompensatedClosable

An open method that should be overriden by subclasses.

openFailed(Throwable) - Method in class net.sf.asyncobjects.Using

This method is called in separate turn in case when open operation failed.

or(Promise<Boolean>...) - Static method in class net.sf.asyncobjects.util.Condition

This operations finishes with false only if all promises resolve to false.

out - Variable in class net.sf.asyncobjects.io.WrappingChannel

and output

OutputStreamAdapter - Class in net.sf.asyncobjects.io.adapters

An adapter for output stream

OutputStreamAdapter(OutputStream) - Constructor for class net.sf.asyncobjects.io.adapters.OutputStreamAdapter

A constructor

OutputStreamAdapter(OutputStream, int) - Constructor for class net.sf.asyncobjects.io.adapters.OutputStreamAdapter

A constructor

P

peek(int, byte[], int, int) - Method in class net.sf.asyncobjects.io.ByteQueue

Peek bytes

peekByte() - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

permitsBalance() - Method in interface net.sf.asyncobjects.util.ASemaphore

permitsBalance() - Method in class net.sf.asyncobjects.util.Semaphore

Pipe<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>,C extends AChannel<D,I,O>> - Class in net.sf.asyncobjects.io

A pipe is pair of output stream and input stream, what is written to output stream, could be later read from input stream.

Pipe(int) - Constructor for class net.sf.asyncobjects.io.Pipe

make a pipe

Pipe.InternalPipeInput - Class in net.sf.asyncobjects.io

This is an internal class.

Pipe.InternalPipeInput() - Constructor for class net.sf.asyncobjects.io.Pipe.InternalPipeInput

a private constructor

Pipe.InternalPipeOutput - Class in net.sf.asyncobjects.io

This is an internal class.

Pipe.InternalPipeOutput() - Constructor for class net.sf.asyncobjects.io.Pipe.InternalPipeOutput

A constructor

pollIdle() - Method in class net.sf.asyncobjects.net.nio.NIOSelectorRunner

poll action, poll should never block.

pollIdle() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

poll action, poll should never block.

position() - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

problem() - Method in class net.sf.asyncobjects.Promise

promise() - Method in class net.sf.asyncobjects.AsyncUnicastServer

promise() - Method in interface net.sf.asyncobjects.io.BatchedData

Return a promise that wraps this value

promise() - Method in class net.sf.asyncobjects.io.BinaryData

promise() - Method in class net.sf.asyncobjects.io.TextData

Promise<T> - Class in net.sf.asyncobjects

A promise represents outcome of some asynchronous operation.

Promise(T) - Constructor for class net.sf.asyncobjects.Promise

A constructor for promise.

Promise() - Constructor for class net.sf.asyncobjects.Promise

A constructor for promise

promise() - Method in class net.sf.asyncobjects.Using

promise() - Method in class net.sf.asyncobjects.util.All

promise() - Method in class net.sf.asyncobjects.util.Any

promise() - Method in class net.sf.asyncobjects.util.AsyncProcess

promise() - Method in class net.sf.asyncobjects.util.Seq

promise() - Method in class net.sf.asyncobjects.util.Serialized

Return a promise for action execution.

promise() - Method in class net.sf.asyncobjects.When

Promise.InternalPromiseResolverImpl - Class in net.sf.asyncobjects

This is an internal class.

purge() - Method in interface net.sf.asyncobjects.util.timer.ATimer

Remove all tasks from the timer

purge() - Method in class net.sf.asyncobjects.util.timer.TimerWrapper

pushback(BinaryData) - Method in class net.sf.asyncobjects.io.adapters.InputStreamAdapter

Pushback data

pushback(D) - Method in interface net.sf.asyncobjects.io.AInput

Attempt to return some data to stream.

pushback(D) - Method in class net.sf.asyncobjects.io.BufferedInput

Push data back to the stream

pushback(TextData) - Method in class net.sf.asyncobjects.io.DecoderTextInput

Push back the data

pushback(D) - Method in class net.sf.asyncobjects.io.Pipe.InternalPipeInput

Push data back to the stream

pushback(D) - Method in class net.sf.asyncobjects.io.Pipe

Push data back to the pipe

pushback(D) - Method in class net.sf.asyncobjects.io.util.BoundedInput

Pushback data

pushback(D) - Method in class net.sf.asyncobjects.io.util.ExhaustingInput

Pushback

pushback(D) - Method in class net.sf.asyncobjects.io.util.GeneratingInput

pushback(D) - Method in class net.sf.asyncobjects.io.util.NulInput

pushback(D) - Method in class net.sf.asyncobjects.io.util.SavingInput

Pushbback some data

pushback(D) - Method in class net.sf.asyncobjects.io.util.UncloseableInput

Pushback

pushback(BinaryData) - Method in class net.sf.asyncobjects.net.nio.NIOSocketInputStream

Push back data

put(ByteBuffer, BinaryData) - Static method in class net.sf.asyncobjects.io.BinaryData

Put binary data into the buffer

put(byte[]) - Method in class net.sf.asyncobjects.io.ByteQueue

Peek bytes

put(byte[], int, int) - Method in class net.sf.asyncobjects.io.ByteQueue

Peek bytes

put(CharBuffer) - Method in class net.sf.asyncobjects.io.TextData

Put data to character buffer

put(T) - Method in interface net.sf.asyncobjects.util.AQueue

Put object from the queue

put(T) - Method in class net.sf.asyncobjects.util.Queue

Q

Queue<T> - Class in net.sf.asyncobjects.util

Object queue.

Queue(int, int) - Constructor for class net.sf.asyncobjects.util.Queue

A constructor

Queue() - Constructor for class net.sf.asyncobjects.util.Queue

A constructor

queue - Variable in class net.sf.asyncobjects.vats.VatQueueRunner

queue that contains vats to execute

R

RandomByteInput - Class in net.sf.asyncobjects.io.util

A random byte input.

RandomByteInput(Random, int) - Constructor for class net.sf.asyncobjects.io.util.RandomByteInput

A constructor for unlmited stream

RandomByteInput(Random) - Constructor for class net.sf.asyncobjects.io.util.RandomByteInput

A constructor for unlimited stream with limit 1024

RandomByteInput() - Constructor for class net.sf.asyncobjects.io.util.RandomByteInput

A constructor for unlimited stream with limit 1024 and generator created with Random.Random()

RandomByteInput(Random, int, long) - Constructor for class net.sf.asyncobjects.io.util.RandomByteInput

A constructor

RandomTextInput - Class in net.sf.asyncobjects.io.util

A random text input.

RandomTextInput(Random, int) - Constructor for class net.sf.asyncobjects.io.util.RandomTextInput

A constructor for unlmited stream

RandomTextInput(Random) - Constructor for class net.sf.asyncobjects.io.util.RandomTextInput

A constructor for unlimited stream with limit 1024

RandomTextInput() - Constructor for class net.sf.asyncobjects.io.util.RandomTextInput

A constructor for unlimited stream with limit 1024 and generator created with Random.Random()

RandomTextInput(Random, int, long) - Constructor for class net.sf.asyncobjects.io.util.RandomTextInput

A constructor

read(int) - Method in class net.sf.asyncobjects.io.adapters.InputStreamAdapter

read some bytes

read(int) - Method in interface net.sf.asyncobjects.io.AInput

Read some data.

read(int) - Method in class net.sf.asyncobjects.io.BufferedInput

read some bytes in buffer

read(int) - Method in class net.sf.asyncobjects.io.DecoderTextInput

read(int) - Method in class net.sf.asyncobjects.io.Pipe.InternalPipeInput

read some bytes

read(int) - Method in class net.sf.asyncobjects.io.util.BoundedInput

Read data

read(int) - Method in class net.sf.asyncobjects.io.util.ExhaustingInput

Read data

read(int) - Method in class net.sf.asyncobjects.io.util.GeneratingInput

read(int) - Method in class net.sf.asyncobjects.io.util.NulInput

read(int) - Method in class net.sf.asyncobjects.io.util.SavingInput

In addition to stantad semantics.

read(int) - Method in class net.sf.asyncobjects.io.util.UncloseableInput

read(int) - Method in class net.sf.asyncobjects.net.nio.NIOSocketInputStream

Read some bytes.

readAll(D, AInput<D>, int) - Static method in class net.sf.asyncobjects.io.IOUtils

Read all data from the stream.

readAll(AByteInput, int) - Static method in class net.sf.asyncobjects.io.IOUtils

Read all data from the stream.

readAll(ATextInput, int) - Static method in class net.sf.asyncobjects.io.IOUtils

Read all data from the stream.

readFully(AByteInput, int) - Static method in class net.sf.asyncobjects.io.IOUtils

Read exactly specified amount data from byte input

readFully(ATextInput, int) - Static method in class net.sf.asyncobjects.io.IOUtils

Read exactly specified amount data from text input

readFully(D, AInput<D>, int) - Static method in class net.sf.asyncobjects.io.IOUtils

Read exactly specified amount data from byte input

RecordingByteOutput - Class in net.sf.asyncobjects.io.util

A recording byte output.

RecordingByteOutput(BinaryData) - Constructor for class net.sf.asyncobjects.io.util.RecordingByteOutput

A constructor

RecordingByteOutput() - Constructor for class net.sf.asyncobjects.io.util.RecordingByteOutput

A constructor

RecordingOutput<D extends BatchedData<D>,O extends AOutput<D>> - Class in net.sf.asyncobjects.io.util

The output that recordes what is written into it.

RecordingOutput(D) - Constructor for class net.sf.asyncobjects.io.util.RecordingOutput

A constructor

RecordingTextOutput - Class in net.sf.asyncobjects.io.util

A recording text output.

RecordingTextOutput(TextData) - Constructor for class net.sf.asyncobjects.io.util.RecordingTextOutput

A constructor

RecordingTextOutput() - Constructor for class net.sf.asyncobjects.io.util.RecordingTextOutput

A constructor

registerChannel(SelectableChannel) - Method in class net.sf.asyncobjects.net.nio.NIOSelectorRunner

register channel with listener

registerChannel(SelectableChannel) - Method in class net.sf.asyncobjects.net.nio.NIOSelectorVat

register channel with listener

release() - Method in interface net.sf.asyncobjects.util.ASemaphore

Release a permit

release(int) - Method in interface net.sf.asyncobjects.util.ASemaphore

Release a number of permits

release() - Method in class net.sf.asyncobjects.util.Semaphore

release(int) - Method in class net.sf.asyncobjects.util.Semaphore

repeat(AOutput<D>, D, long) - Static method in class net.sf.asyncobjects.io.IOUtils

Write specified binary data repeating it until length bytes are written.

RepeatingByteInput - Class in net.sf.asyncobjects.io.util

A repeating byte input

RepeatingByteInput(BinaryData, long) - Constructor for class net.sf.asyncobjects.io.util.RepeatingByteInput

A consructor

RepeatingByteInput(BinaryData) - Constructor for class net.sf.asyncobjects.io.util.RepeatingByteInput

A consructor

RepeatingInput<D extends BatchedData<D>,I extends AInput<D>> - Class in net.sf.asyncobjects.io.util

An input that repeats specified data over and over.

RepeatingInput(D) - Constructor for class net.sf.asyncobjects.io.util.RepeatingInput

A consructor

RepeatingInput(D, long) - Constructor for class net.sf.asyncobjects.io.util.RepeatingInput

A consructor

RepeatingTextInput - Class in net.sf.asyncobjects.io.util

A repeating text input.

RepeatingTextInput(TextData, long) - Constructor for class net.sf.asyncobjects.io.util.RepeatingTextInput

A consructor

RepeatingTextInput(TextData) - Constructor for class net.sf.asyncobjects.io.util.RepeatingTextInput

A consructor

replaceWith(String) - Method in class net.sf.asyncobjects.io.DecoderTextInput

Configure reprelacement string for decoder

replaceWith(byte[]) - Method in class net.sf.asyncobjects.io.EncoderTextOutput

Specify replacement

RequestQueue - Class in net.sf.asyncobjects.util

This utiliy class represent request queue.

RequestQueue() - Constructor for class net.sf.asyncobjects.util.RequestQueue

requests - Variable in class net.sf.asyncobjects.util.CloseableWrapper

a request queue

resetCurrentVat() - Method in class net.sf.asyncobjects.vats.Vat

Disassociate thread from vat

resolve(T) - Method in interface net.sf.asyncobjects.AResolver

Resolve promise with value which is a result of successful execution of the operation.

resolve(T) - Method in class net.sf.asyncobjects.Promise.InternalPromiseResolverImpl

resolve promise

resolve(I) - Method in class net.sf.asyncobjects.When.InternalArgumentListener

Resolve method

resolve(R) - Method in class net.sf.asyncobjects.When.InternalBodyPromiseResolver

Resolve method

resolve(Object) - Method in class net.sf.asyncobjects.When.InternalFinallyListenerAfterFault

Resolve method

resolve(Object) - Method in class net.sf.asyncobjects.When.InternalFinallyListenerAfterSuccess

Resolve method

resolve(R) - Method in class net.sf.asyncobjects.When.InternalResultPromiseResolver

This is a callback method which is called when promise is resolved.

RESOLVED - Static variable in class net.sf.asyncobjects.Promise

resolved state

resolved(I) - Method in class net.sf.asyncobjects.When

This method is called when promise is overloaded in subclasses.

resolver() - Method in class net.sf.asyncobjects.Promise

Get resolver for this promise.

resumeInCurrentThread() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

resumeInCurrentThread() - Method in class net.sf.asyncobjects.vats.SingleThreadRunner

resumeInCurrentThread() - Method in interface net.sf.asyncobjects.vats.ThreadBasedRunner

This methods resumes the suspended runner in the current thread.

returnByteBuffer(ByteBuffer) - Method in interface net.sf.asyncobjects.io.BufferProvider

Return the buffer

returnByteBuffer(ByteBuffer) - Method in class net.sf.asyncobjects.io.DefaultBufferProvider

returnCharBuffer(CharBuffer) - Method in interface net.sf.asyncobjects.io.BufferProvider

Return the buffer

returnCharBuffer(CharBuffer) - Method in class net.sf.asyncobjects.io.DefaultBufferProvider

returnDirectBuffer(ByteBuffer) - Method in class net.sf.asyncobjects.net.nio.NIOSelectorRunner

Return buffer to the runner

returnDirectBuffer(ByteBuffer) - Method in class net.sf.asyncobjects.net.nio.NIOStream

Return buffer to the runner

run() - Method in class net.sf.asyncobjects.AsyncAction

This abstract method is basically "main" for vat.

run(S) - Method in class net.sf.asyncobjects.Using

This method should be implemented by subclasses.

run() - Method in class net.sf.asyncobjects.util.AsyncProcess

Process body.

run() - Method in class net.sf.asyncobjects.util.callbacks.RunnableAdapter.InternalRunnableAdapter

run() - Method in class net.sf.asyncobjects.util.callbacks.RunnableAdapter

Run action

run() - Method in class net.sf.asyncobjects.util.Compensated

Run primary action.

run() - Method in class net.sf.asyncobjects.util.CompensatedClosable

run() - Method in class net.sf.asyncobjects.util.Serialized

Action that should be queue on request queue

run(long) - Method in interface net.sf.asyncobjects.util.timer.ATimerTask

Run the task

run(long) - Method in class net.sf.asyncobjects.util.timer.TimerTaskAdapter.InternalTimerTask

run(long) - Method in class net.sf.asyncobjects.util.timer.TimerTaskAdapter

Run the task.

run() - Method in class net.sf.asyncobjects.vats.VatQueueRunner.EnqueuedVat

The default run method.

run1() - Method in class net.sf.asyncobjects.util.RunDispatcher

First action

run10() - Method in class net.sf.asyncobjects.util.RunDispatcher

10th action

run11() - Method in class net.sf.asyncobjects.util.RunDispatcher

11th action

run12() - Method in class net.sf.asyncobjects.util.RunDispatcher

12th action

run13() - Method in class net.sf.asyncobjects.util.RunDispatcher

13th action

run14() - Method in class net.sf.asyncobjects.util.RunDispatcher

14th action

run15() - Method in class net.sf.asyncobjects.util.RunDispatcher

15th action

run16() - Method in class net.sf.asyncobjects.util.RunDispatcher

16th action

run2() - Method in class net.sf.asyncobjects.util.RunDispatcher

Second action

run3() - Method in class net.sf.asyncobjects.util.RunDispatcher

3rd action

run4() - Method in class net.sf.asyncobjects.util.RunDispatcher

4th action

run5() - Method in class net.sf.asyncobjects.util.RunDispatcher

5th action

run6() - Method in class net.sf.asyncobjects.util.RunDispatcher

6th action

run7() - Method in class net.sf.asyncobjects.util.RunDispatcher

7th action

run8() - Method in class net.sf.asyncobjects.util.RunDispatcher

8th action

run9() - Method in class net.sf.asyncobjects.util.RunDispatcher

9th action

RunDispatcher - Class in net.sf.asyncobjects.util

This is an utility class that is used for serveral control constructs.

RunDispatcher() - Constructor for class net.sf.asyncobjects.util.RunDispatcher

runInCurrentThread(Vat, ThreadBasedRunner, AsyncAction<T>) - Static method in class net.sf.asyncobjects.vats.VatUtils

This is an extremely tricky method.

runInCurrentThread(Vat, AsyncAction<T>) - Static method in class net.sf.asyncobjects.vats.VatUtils

The version of runInCurrentThread(Vat, ThreadBasedRunner, AsyncAction) that uses SingleThreadRunner as runner.

RunnableAdapter - Class in net.sf.asyncobjects.util.callbacks

A runnable adapter that allows using anonymouns inner classes for implementing the ARunnable interface.

RunnableAdapter() - Constructor for class net.sf.asyncobjects.util.callbacks.RunnableAdapter

RunnableAdapter.InternalRunnableAdapter - Class in net.sf.asyncobjects.util.callbacks

An internal class that addapt Adapter calss to asynchronous interface.

runner() - Method in class net.sf.asyncobjects.net.nio.NIOSelectorVat

runner() - Method in class net.sf.asyncobjects.vats.Vat

runNext() - Method in class net.sf.asyncobjects.util.RunDispatcher

S

SavingByteInput - Class in net.sf.asyncobjects.io.util

A saving byte input

SavingByteInput(AByteInput, boolean, AByteOutput) - Constructor for class net.sf.asyncobjects.io.util.SavingByteInput

A constructor

SavingInput<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>> - Class in net.sf.asyncobjects.io.util

This utility stream allows to save all data read from byte input to some output.

SavingInput(I, boolean, O) - Constructor for class net.sf.asyncobjects.io.util.SavingInput

A constructor

SavingTextInput - Class in net.sf.asyncobjects.io.util

A saving text input

SavingTextInput(ATextInput, boolean, ATextOutput) - Constructor for class net.sf.asyncobjects.io.util.SavingTextInput

A constructor

schedule(long, ATimerTask) - Method in interface net.sf.asyncobjects.util.timer.ATimer

Schedule task after specified delay

schedule(Date, ATimerTask) - Method in interface net.sf.asyncobjects.util.timer.ATimer

Schedule task at specified time

schedule(long, long, ATimerTask) - Method in interface net.sf.asyncobjects.util.timer.ATimer

Schedule task after specfied delay with specified period

schedule(Date, long, ATimerTask) - Method in interface net.sf.asyncobjects.util.timer.ATimer

Schedule task after specfied time with specified period

schedule(long, ATimerTask) - Method in class net.sf.asyncobjects.util.timer.TimerWrapper

schedule(Date, ATimerTask) - Method in class net.sf.asyncobjects.util.timer.TimerWrapper

schedule(long, long, ATimerTask) - Method in class net.sf.asyncobjects.util.timer.TimerWrapper

schedule(Date, long, ATimerTask) - Method in class net.sf.asyncobjects.util.timer.TimerWrapper

scheduleAtFixedRate(long, long, ATimerTask) - Method in interface net.sf.asyncobjects.util.timer.ATimer

Schedule task after specfied delay with fixed rate

scheduleAtFixedRate(Date, long, ATimerTask) - Method in interface net.sf.asyncobjects.util.timer.ATimer

Schedule task after specfied time with fixed rage

scheduleAtFixedRate(long, long, ATimerTask) - Method in class net.sf.asyncobjects.util.timer.TimerWrapper

scheduleAtFixedRate(Date, long, ATimerTask) - Method in class net.sf.asyncobjects.util.timer.TimerWrapper

Semaphore - Class in net.sf.asyncobjects.util

Asynchronous semaphore service.

Semaphore(int) - Constructor for class net.sf.asyncobjects.util.Semaphore

Create semaphore with specified number of permits.

Seq<R> - Class in net.sf.asyncobjects.util

A sequence control construct.

Seq() - Constructor for class net.sf.asyncobjects.util.Seq

A constructor.

Serialized<T> - Class in net.sf.asyncobjects.util

This class respresents action serialized over request queue.

Serialized(RequestQueue) - Constructor for class net.sf.asyncobjects.util.Serialized

A constructor from queue

setBachingFactor(int) - Method in class net.sf.asyncobjects.vats.VatRunner

Set batching factor

setCurrentVat(Object) - Method in class net.sf.asyncobjects.vats.Vat

Associate this thread with this vat

setPollInterval(int) - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

Set poll interval

setStarted() - Method in class net.sf.asyncobjects.vats.VatRunner

Set state to started

setStarting() - Method in class net.sf.asyncobjects.vats.VatRunner

Set state to starting

setState(VatRunner.VatRunnerState) - Method in class net.sf.asyncobjects.vats.VatRunner

setStopped() - Method in class net.sf.asyncobjects.vats.VatRunner

Set stopped state

setStopping() - Method in class net.sf.asyncobjects.vats.VatRunner

Set stoppong state

setTcpNoDelay(boolean) - Method in interface net.sf.asyncobjects.net.ASocket

Set TCP_NODELAY option

setTcpNoDelay(boolean) - Method in class net.sf.asyncobjects.net.nio.NIOSocket

Set TCP_NODELAY option

setTcpNoDelay(boolean) - Method in class net.sf.asyncobjects.net.threading.TSocket

Shared<T> - Class in net.sf.asyncobjects

This wrapper object is used to explicitly return values from asynchronous operations which are usually unsafe or unrecommended to return.

Shared(T) - Constructor for class net.sf.asyncobjects.Shared

A constructor

shortAt(int) - Method in class net.sf.asyncobjects.io.BinaryData

Get big endian short at the specified posion.

shutdownStream() - Method in class net.sf.asyncobjects.net.nio.NIOSocketInputStream

shutdownStream() - Method in class net.sf.asyncobjects.net.nio.NIOSocketOutputStream

shutdownStream() - Method in class net.sf.asyncobjects.net.nio.NIOStream

Shutdown stream

SingleThreadIdleRunner - Class in net.sf.asyncobjects.vats

This base class for runners allows executing some idle action instead of blocking on vat queue.

SingleThreadIdleRunner(String, boolean) - Constructor for class net.sf.asyncobjects.vats.SingleThreadIdleRunner

A constructor

SingleThreadIdleRunner() - Constructor for class net.sf.asyncobjects.vats.SingleThreadIdleRunner

A constructor

SingleThreadRunner - Class in net.sf.asyncobjects.vats

This is a single thread runner.

SingleThreadRunner(String, boolean) - Constructor for class net.sf.asyncobjects.vats.SingleThreadRunner

A constructor

SingleThreadRunner() - Constructor for class net.sf.asyncobjects.vats.SingleThreadRunner

A constructor

skip(int) - Method in class net.sf.asyncobjects.io.BinaryData.ByteIterator

Skip n bytes

skip(int) - Method in class net.sf.asyncobjects.io.ByteQueue

consume some bytes in buffer

sleepFor(ATimer, long) - Static method in class net.sf.asyncobjects.util.timer.TimerUtils

Sleep the specified amount of milliseconds

sleepUntil(ATimer, Date) - Static method in class net.sf.asyncobjects.util.timer.TimerUtils

Sleep the specified amount of milliseconds

smash(Throwable) - Method in interface net.sf.asyncobjects.AResolver

Smash the promise with exception.

smash(Throwable) - Method in class net.sf.asyncobjects.Promise.InternalPromiseResolverImpl

break promise with exception

smash(Throwable) - Method in class net.sf.asyncobjects.util.Queue

Smash all pending waiters in the queue

smash(Throwable) - Method in class net.sf.asyncobjects.When.InternalArgumentListener

Smash method

smash(Throwable) - Method in class net.sf.asyncobjects.When.InternalBodyPromiseResolver

Smash method

smash(Throwable) - Method in class net.sf.asyncobjects.When.InternalFinallyListenerAfterFault

Smash method

smash(Throwable) - Method in class net.sf.asyncobjects.When.InternalFinallyListenerAfterSuccess

Smash method

smash(Throwable) - Method in class net.sf.asyncobjects.When.InternalResultPromiseResolver

Smash method

SMASHED - Static variable in class net.sf.asyncobjects.Promise

broken state

smashed(Throwable) - Static method in class net.sf.asyncobjects.Promise

Create smashed promise

smashed(int, Throwable) - Method in class net.sf.asyncobjects.util.All

Handle fault on one of actions.

smashed(Throwable) - Method in class net.sf.asyncobjects.util.AsyncProcess.ProcessWhen

This imlementation just fails process using AsyncProcess.failure(Throwable) method.

smashed(Throwable) - Method in class net.sf.asyncobjects.util.CloseableWrapper.InvalidatingWhen

In addition to base class functionaity, the stream is marked as invalid.

smashed(int, Throwable) - Method in class net.sf.asyncobjects.util.Seq

Handle fault on one of actions.

smashed(Throwable) - Method in class net.sf.asyncobjects.When

This method is called when argument promise is broken.

start() - Method in class net.sf.asyncobjects.io.ByteStreamForwarder

Deprecated. start reading from one stream and writing to another.

startInCurrentThread() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

Start runner in the current thread.

startInCurrentThread() - Method in class net.sf.asyncobjects.vats.SingleThreadRunner

Start runner in the current thread.

startInCurrentThread() - Method in interface net.sf.asyncobjects.vats.ThreadBasedRunner

Start runner in the current thread.

startInNewThread() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

Start vat in new thread

startInNewThread() - Method in class net.sf.asyncobjects.vats.SingleThreadRunner

Start runner in new thread

startInNewThread() - Method in interface net.sf.asyncobjects.vats.ThreadBasedRunner

Start runner in new thread

startRequest() - Method in class net.sf.asyncobjects.util.RequestQueue

start performing request, usually this method is called after noPending or ready.

state - Variable in class net.sf.asyncobjects.vats.Vat

state of vat, guarded by state lock

state - Variable in class net.sf.asyncobjects.vats.VatRunner

a state of vat runner

stateLock - Variable in class net.sf.asyncobjects.vats.Vat

state lock

stateLock - Variable in class net.sf.asyncobjects.vats.VatRunner

a state lock

stop() - Method in class net.sf.asyncobjects.net.nio.NIOSelectorRunner

stop() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

Stop this runner

stop() - Method in class net.sf.asyncobjects.vats.SingleThreadRunner

Stop this runner

stop() - Method in interface net.sf.asyncobjects.vats.ThreadBasedRunner

Stop this runner

stopped() - Method in class net.sf.asyncobjects.net.nio.NIOSelectorRunner

stop action

stopped() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

After vat is stopped

stopping() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

Stopping the vat

subrange(int, int) - Method in interface net.sf.asyncobjects.io.BatchedData

Get subrange of data

subrange(int, int) - Method in class net.sf.asyncobjects.io.BinaryData

subrange(int, int) - Method in class net.sf.asyncobjects.io.TextData

subSequence(int, int) - Method in class net.sf.asyncobjects.io.TextData

success(R) - Method in class net.sf.asyncobjects.util.AsyncProcess

Subclasses should call this method to indicate that process finished successfully.

success(Promise<R>) - Method in class net.sf.asyncobjects.util.AsyncProcess

Subclasses should call this method to indicate that process finished successfully.

suspend() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

suspend() - Method in class net.sf.asyncobjects.vats.SingleThreadRunner

suspend() - Method in interface net.sf.asyncobjects.vats.ThreadBasedRunner

This method cases the runner to suspend its work.

T

TextData - Class in net.sf.asyncobjects.io

A textual data batch.

TextPipe - Class in net.sf.asyncobjects.io

A pipe is pair of output stream and input stream, what is written to output stream, could be later read from input stream.

TextPipe(int) - Constructor for class net.sf.asyncobjects.io.TextPipe

make a pipe

TextPipe.InternalTextPipeInput - Class in net.sf.asyncobjects.io

Pipe input

TextPipe.InternalTextPipeOutput - Class in net.sf.asyncobjects.io

Pipe output

ThreadBasedRunner - Interface in net.sf.asyncobjects.vats

This interface is supported by runners that might occupy the thread.

ticket - Variable in class net.sf.asyncobjects.vats.Vat

a running ticket, guarded by state lock

ticket - Variable in class net.sf.asyncobjects.vats.VatQueueRunner.EnqueuedVat

a ticket

timeout(ATimer, long, Throwable) - Static method in class net.sf.asyncobjects.util.timer.TimerUtils

Smash result promise with the specified exception after specified time

timeoutAt(ATimer, Date, Throwable) - Static method in class net.sf.asyncobjects.util.timer.TimerUtils

Smash result promise with the specified exception after specified time

TimerTaskAdapter - Class in net.sf.asyncobjects.util.timer

An adapter that helps to impelemnt time tasks.

TimerTaskAdapter() - Constructor for class net.sf.asyncobjects.util.timer.TimerTaskAdapter

TimerTaskAdapter.InternalTimerTask - Class in net.sf.asyncobjects.util.timer

Internal class that acutally implemetns interface

TimerUtils - Class in net.sf.asyncobjects.util.timer

Timer utils that provide simplified interface.

TimerUtils() - Constructor for class net.sf.asyncobjects.util.timer.TimerUtils

TimerWrapper - Class in net.sf.asyncobjects.util.timer

A timer wrapper.

TimerWrapper(Timer, boolean, boolean) - Constructor for class net.sf.asyncobjects.util.timer.TimerWrapper

A constructor

TimerWrapper(Timer) - Constructor for class net.sf.asyncobjects.util.timer.TimerWrapper

A constructor

toArray(int, byte[], int, int) - Method in class net.sf.asyncobjects.io.BinaryData

Copy data to byte array

toArray() - Method in class net.sf.asyncobjects.io.BinaryData

toBinaryData() - Method in class net.sf.asyncobjects.io.BinaryDataBuilder

toString() - Method in class net.sf.asyncobjects.io.BinaryData

toString() - Method in class net.sf.asyncobjects.io.TextData

toStrings() - Method in class net.sf.asyncobjects.io.TextData

toVoid() - Method in class net.sf.asyncobjects.Promise

Convert promise to promise for void

toVoid(Promise<?>) - Static method in class net.sf.asyncobjects.Promise

Convert promise to promise for void

transferFrom(ByteQueue) - Method in class net.sf.asyncobjects.io.ByteQueue

transfer data from one buffer to another, this method gets data from first buffer by method gets, so data is consumed.

truePromise() - Static method in class net.sf.asyncobjects.util.Condition

tryStartRequest() - Method in class net.sf.asyncobjects.util.RequestQueue

TServerSocket - Class in net.sf.asyncobjects.net.threading

Threading server socket

TServerSocket(VatRunner) - Constructor for class net.sf.asyncobjects.net.threading.TServerSocket

A constructor

TSocket - Class in net.sf.asyncobjects.net.threading

implementation of socket with threads. jdk 1.3 required.

TSocket(VatRunner) - Constructor for class net.sf.asyncobjects.net.threading.TSocket

A constructor

TSocket(VatRunner, Socket) - Constructor for class net.sf.asyncobjects.net.threading.TSocket

A socket

TSocket.TInputStreamAdapter - Class in net.sf.asyncobjects.net.threading

Adapter for socket's input stream.

TSocket.TOutputStreamAdapter - Class in net.sf.asyncobjects.net.threading

Adapter for socket output stream.

TSocketFactory - Class in net.sf.asyncobjects.net.threading

A socket factory that creates thread based sockets

U

UncloseableByteInput - Class in net.sf.asyncobjects.io.util

Uncloseable byte input

UncloseableByteInput(AByteInput) - Constructor for class net.sf.asyncobjects.io.util.UncloseableByteInput

A constructor

UncloseableInput<D extends BatchedData<D>,I extends AInput<D>> - Class in net.sf.asyncobjects.io.util

A stream that instead of closing underlying stream just resolves CloseableWrapper.closed() promise.

UncloseableInput(I) - Constructor for class net.sf.asyncobjects.io.util.UncloseableInput

A constructor

UncloseableTextInput - Class in net.sf.asyncobjects.io.util

Uncloseable text input

UncloseableTextInput(ATextInput) - Constructor for class net.sf.asyncobjects.io.util.UncloseableTextInput

A constructor

UNLIMITED - Static variable in class net.sf.asyncobjects.io.IOUtils

an unlmited value

UNLIMITED - Static variable in class net.sf.asyncobjects.io.util.GeneratingInput

a unlimited value

UNRESOLVED - Static variable in class net.sf.asyncobjects.Promise

unresolved state

upcast(Promise<? extends A>) - Static method in class net.sf.asyncobjects.Promise

Upcast the promise.

Using<S extends ACloseable,T> - Class in net.sf.asyncobjects

This is an utility class that executes some action and than closes resource that implements the interface ACloseable after activity in the body finishes.

Using(Promise<S>) - Constructor for class net.sf.asyncobjects.Using

A constructor

Using(S) - Constructor for class net.sf.asyncobjects.Using

A constructor

V

value() - Method in class net.sf.asyncobjects.Promise

value - Variable in class net.sf.asyncobjects.Shared

a shared value

valueOf(boolean) - Static method in class net.sf.asyncobjects.util.Condition

Return promise that represents a boolean value

valueOf(String) - Static method in enum net.sf.asyncobjects.vats.Vat.VatState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum net.sf.asyncobjects.vats.VatRunner.VatRunnerState

Returns the enum constant of this type with the specified name.

values() - Static method in enum net.sf.asyncobjects.vats.Vat.VatState

Returns an array containing the constants of this enum type, in the order they're declared.

values() - Static method in enum net.sf.asyncobjects.vats.VatRunner.VatRunnerState

Returns an array containing the constants of this enum type, in the order they're declared.

Vat - Class in net.sf.asyncobjects.vats

Vat is managed collection of objects.

Vat(VatRunner, String) - Constructor for class net.sf.asyncobjects.vats.Vat

a constructor

Vat(VatRunner) - Constructor for class net.sf.asyncobjects.vats.Vat

a constructor

Vat(String) - Constructor for class net.sf.asyncobjects.vats.Vat

a constructor

Vat() - Constructor for class net.sf.asyncobjects.vats.Vat

a constructor

vat - Variable in class net.sf.asyncobjects.vats.VatQueueRunner.EnqueuedVat

a vat

Vat.VatState - Enum in net.sf.asyncobjects.vats

Vat state

VatFactory - Interface in net.sf.asyncobjects.vats

This interface is for factory that creates vats.

VatQueueRunner - Class in net.sf.asyncobjects.vats

This is a runner that has own queue of vats.

VatQueueRunner() - Constructor for class net.sf.asyncobjects.vats.VatQueueRunner

VatQueueRunner.EnqueuedVat - Class in net.sf.asyncobjects.vats

An enqueued vat

VatQueueRunner.EnqueuedVat(Vat, Object) - Constructor for class net.sf.asyncobjects.vats.VatQueueRunner.EnqueuedVat

A constructor

VatRunner - Class in net.sf.asyncobjects.vats

This is a base class for vat runners.

VatRunner() - Constructor for class net.sf.asyncobjects.vats.VatRunner

VatRunner.VatRunnerState - Enum in net.sf.asyncobjects.vats

Vat state

VatSensor - Interface in net.sf.asyncobjects.vats

A vat sensor.

VatUtils - Class in net.sf.asyncobjects.vats

This class contains some experimental vat utilities

VatUtils() - Constructor for class net.sf.asyncobjects.vats.VatUtils

W

Wait - Class in net.sf.asyncobjects.util

This utility class allows waiting on some conditions related to promises.

Wait() - Constructor for class net.sf.asyncobjects.util.Wait

waitAcceptable(SelectionKey) - Method in class net.sf.asyncobjects.net.nio.NIOSelectorVat

wait until socket will became acceptable

WaitAllException - Exception in net.sf.asyncobjects.util

This exception is thrown from Wait.all operation if there are failures.

WaitAllException(List<Object>, List<Throwable>) - Constructor for exception net.sf.asyncobjects.util.WaitAllException

A constructor from partial results and failures

waitConnectable(SelectionKey) - Method in class net.sf.asyncobjects.net.nio.NIOSelectorVat

wait until socket will became ready to finish connection

waitReadable(SelectionKey) - Method in class net.sf.asyncobjects.net.nio.NIOSelectorVat

wait until socket will became readable

waitWritable(SelectionKey) - Method in class net.sf.asyncobjects.net.nio.NIOSelectorVat

wait until socket will became writable

wakeupIdle() - Method in class net.sf.asyncobjects.net.nio.NIOSelectorRunner

wakeup idle action and perform, wakeupIdle should be ready to fact that it will be called several times and that it could be called before actual entering into idle call.

wakeupIdle() - Method in class net.sf.asyncobjects.vats.SingleThreadIdleRunner

wakeup idle action and perform, wakeupIdle should be ready to fact that it will be called several times and that it could be called before actual entering into idle call.

was(T, Promise<?>) - Static method in class net.sf.asyncobjects.util.Condition

Check if value matches expected using Object.equals(Object).

When<I,R> - Class in net.sf.asyncobjects

When construct support class.

When(Promise<? extends I>) - Constructor for class net.sf.asyncobjects.When

A constructor from promise.

When(I) - Constructor for class net.sf.asyncobjects.When

A constructor from value.

When.InternalArgumentListener - Class in net.sf.asyncobjects

This is an internal class.

When.InternalBodyPromiseResolver - Class in net.sf.asyncobjects

This is an internal class.

When.InternalFinallyListenerAfterFault - Class in net.sf.asyncobjects

This is an internal class.

When.InternalFinallyListenerAfterSuccess - Class in net.sf.asyncobjects

This is an internal class.

When.InternalResultPromiseResolver - Class in net.sf.asyncobjects

This is internal class.

willBe(Class<P>) - Method in class net.sf.asyncobjects.Promise

This method allows creation of the proxy that allows sending message to resolution before promise is resolved.

with(T) - Static method in class net.sf.asyncobjects.Promise

Get promise with value

wrap(AByteInput) - Method in class net.sf.asyncobjects.io.BufferedByteChannel

Wrap input into buffered stream

wrap(AByteOutput) - Method in class net.sf.asyncobjects.io.BufferedByteChannel

Wrap output into buffered stream

wrap(ATextInput) - Method in class net.sf.asyncobjects.io.BufferedTextChannel

Wrap input into buffered stream

wrap(ATextOutput) - Method in class net.sf.asyncobjects.io.BufferedTextChannel

Wrap output into buffered stream

wrap(I) - Method in class net.sf.asyncobjects.io.WrappingChannel

Wrap input into buffered stream

wrap(O) - Method in class net.sf.asyncobjects.io.WrappingChannel

Wrap output into buffered stream

wrap(Callable<V>) - Static method in class net.sf.asyncobjects.util.callbacks.CallableAdapter

Wrap Callable object into asynchronous object

wrap(Runnable) - Static method in class net.sf.asyncobjects.util.callbacks.RunnableAdapter

Wrap Runnable object into asynchronous object.

wrapped - Variable in class net.sf.asyncobjects.io.WrappingChannel

a wrapped byte channel

wrapped - Variable in class net.sf.asyncobjects.util.CloseableWrapper

wrapped closeable

WrappingChannel<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>,C extends AChannel<D,I,O>> - Class in net.sf.asyncobjects.io

Byte channel that wraps existing channel some functionality over it.

WrappingChannel(C) - Constructor for class net.sf.asyncobjects.io.WrappingChannel

A constructor

write(BinaryData) - Method in class net.sf.asyncobjects.io.adapters.OutputStreamAdapter

Write data to stream

write(D) - Method in interface net.sf.asyncobjects.io.AOutput

This method writes out the data.

write(D) - Method in class net.sf.asyncobjects.io.BufferedOutput

write data

write(TextData) - Method in class net.sf.asyncobjects.io.EncoderTextOutput

Encode data

write(D) - Method in class net.sf.asyncobjects.io.Pipe.InternalPipeOutput

Write data to stream

write(D) - Method in class net.sf.asyncobjects.io.util.MulticastOutput

Write data

write(D) - Method in class net.sf.asyncobjects.io.util.RecordingOutput

write(BinaryData) - Method in class net.sf.asyncobjects.net.nio.NIOSocketOutputStream

Write data

A B C D E F G H I L M N O P Q R S T U V W