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

Copyright 2002-2007 Constantine Plotnikov. All Rights Reserved.