|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ExplicitSharing | |
---|---|
net.sf.asyncobjects | The core classes of the framework. |
net.sf.asyncobjects.io | This package contains core IO interfaces. |
net.sf.asyncobjects.io.adapters | This package contains adapters to blocking java streams. |
net.sf.asyncobjects.io.util | This package contains uitility input and output streams. |
net.sf.asyncobjects.net.nio | This package contains implementation of network interfaces that is based on non-blocking NIO socket API. |
net.sf.asyncobjects.net.threading | This package contains implementation of network interfaces that is based on blocking socket API. |
net.sf.asyncobjects.util | This package contains generic utilities that helps to develop asynchronous operations. |
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 | This package contains generic timer interfaces and implementation
of them over Timer nad TimerTask
classes. |
Uses of ExplicitSharing in net.sf.asyncobjects |
---|
Classes in net.sf.asyncobjects that implement ExplicitSharing | |
---|---|
class |
AsyncUnicastServer<T extends AsyncObject>
Unicast server implementation. |
class |
Promise<T>
A promise represents outcome of some asynchronous operation. |
class |
Promise.InternalPromiseResolverImpl
This is an internal class. |
class |
Using<S extends ACloseable,T>
This is an utility class that executes some action and than closes resource that implements the interface ACloseable after activity in the body
finishes. |
class |
When<I,R>
When construct support class. |
class |
When.InternalArgumentListener
This is an internal class. |
class |
When.InternalBodyPromiseResolver
This is an internal class. |
class |
When.InternalFinallyListenerAfterFault
This is an internal class. |
class |
When.InternalFinallyListenerAfterSuccess
This is an internal class. |
class |
When.InternalResultPromiseResolver
This is internal class. |
Uses of ExplicitSharing in net.sf.asyncobjects.io |
---|
Classes in net.sf.asyncobjects.io that implement ExplicitSharing | |
---|---|
class |
BufferedByteChannel
Byte channel that wraps existing channel and adds buffering functionality over it. |
class |
BufferedByteInput
A buffered byte input stream. |
class |
BufferedByteOutput
Buffered output. |
class |
BufferedInput<D extends BatchedData<D>,I extends AInput<D>>
A buffered input stream. |
class |
BufferedOutput<D extends BatchedData<D>,O extends AOutput<D>>
Buffered output. |
class |
BufferedTextChannel
Text channel that wraps existing channel and adds buffering functionality over it. |
class |
BufferedTextInput
A buffered Text input stream. |
class |
BufferedTextOutput
Buffered output. |
class |
BytePipe
A pipe is pair of output stream and input stream, what is written to output stream, could be later read from input stream. |
class |
BytePipe.InternalBytePipeInput
Pipe input |
class |
BytePipe.InternalBytePipeOutput
Pipe output |
class |
DecoderTextInput
A text input that uses CharsetDecoder to convert byte input to
character input. |
class |
EncoderTextOutput
An output that encodes the text into binary. |
class |
Pipe<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>,C extends AChannel<D,I,O>>
A pipe is pair of output stream and input stream, what is written to output stream, could be later read from input stream. |
class |
Pipe.InternalPipeInput
This is an internal class. |
class |
Pipe.InternalPipeOutput
This is an internal class. |
class |
TextPipe
A pipe is pair of output stream and input stream, what is written to output stream, could be later read from input stream. |
class |
TextPipe.InternalTextPipeInput
Pipe input |
class |
TextPipe.InternalTextPipeOutput
Pipe output |
class |
WrappingChannel<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>,C extends AChannel<D,I,O>>
Byte channel that wraps existing channel some functionality over it. |
Uses of ExplicitSharing in net.sf.asyncobjects.io.adapters |
---|
Classes in net.sf.asyncobjects.io.adapters that implement ExplicitSharing | |
---|---|
class |
InputStreamAdapter
Adapter for input stream |
class |
OutputStreamAdapter
An adapter for output stream |
Uses of ExplicitSharing in net.sf.asyncobjects.io.util |
---|
Classes in net.sf.asyncobjects.io.util that implement ExplicitSharing | |
---|---|
class |
BoundedByteInput
Bounded byte input. |
class |
BoundedInput<D extends BatchedData<D>,I extends AInput<D>>
Input that allows to read at most the specified length. |
class |
BoundedTextInput
Bounded Text input. |
class |
ExhaustingByteInput
Byte version of ExhaustingInput . |
class |
ExhaustingInput<D extends BatchedData<D>,I extends AInput<D>>
This input waits until stream is fully readed. |
class |
ExhaustingTextInput
Text version of ExhaustingInput . |
class |
GeneratingInput<D extends BatchedData<D>,I extends AInput<D>>
A input that generates some data. |
class |
MulticastByteOutput
Byte version of MulticastOutput |
class |
MulticastOutput<D extends BatchedData<D>,O extends AOutput<D>>
A stream that copies data written to it into streams passed to it as arguments. |
class |
MulticastTextOutput
Text version of MulticastOutput |
class |
NulByteInput
A nul byte input. |
class |
NulInput<D extends BatchedData<D>,I extends AInput<D>>
A zero lenght stream. |
class |
NulTextInput
A nul text input. |
class |
RandomByteInput
A random byte input. |
class |
RandomTextInput
A random text input. |
class |
RecordingByteOutput
A recording byte output. |
class |
RecordingOutput<D extends BatchedData<D>,O extends AOutput<D>>
The output that recordes what is written into it. |
class |
RecordingTextOutput
A recording text output. |
class |
RepeatingByteInput
A repeating byte input |
class |
RepeatingInput<D extends BatchedData<D>,I extends AInput<D>>
An input that repeats specified data over and over. |
class |
RepeatingTextInput
A repeating text input. |
class |
SavingByteInput
A saving byte input |
class |
SavingInput<D extends BatchedData<D>,I extends AInput<D>,O extends AOutput<D>>
This utility stream allows to save all data read from byte input to some output. |
class |
SavingTextInput
A saving text input |
class |
UncloseableByteInput
Uncloseable byte input |
class |
UncloseableInput<D extends BatchedData<D>,I extends AInput<D>>
A stream that instead of closing underlying stream just resolves CloseableWrapper.closed() promise. |
class |
UncloseableTextInput
Uncloseable text input |
Uses of ExplicitSharing in net.sf.asyncobjects.net.nio |
---|
Classes in net.sf.asyncobjects.net.nio that implement ExplicitSharing | |
---|---|
class |
NIOServerSocket
Implementation of server sockets based on nio. |
class |
NIOSocket
NIO-based implementation of socket |
class |
NIOSocketFactory
NIO socket factory, this factory could be created only in context of NIO selector vat. |
class |
NIOSocketInputStream
implementation of stream for sockets |
class |
NIOSocketOutputStream
Output stream based on SocketChannel . |
class |
NIOStream<T extends ACloseable>
Base class for NIO Streams. |
Uses of ExplicitSharing in net.sf.asyncobjects.net.threading |
---|
Classes in net.sf.asyncobjects.net.threading that implement ExplicitSharing | |
---|---|
class |
TServerSocket
Threading server socket |
class |
TSocket
implementation of socket with threads. jdk 1.3 required. |
class |
TSocket.TInputStreamAdapter
Adapter for socket's input stream. |
class |
TSocket.TOutputStreamAdapter
Adapter for socket output stream. |
class |
TSocketFactory
A socket factory that creates thread based sockets |
Uses of ExplicitSharing in net.sf.asyncobjects.util |
---|
Classes in net.sf.asyncobjects.util that implement ExplicitSharing | |
---|---|
class |
All
This control construct waits for all child actions. |
class |
Any
This class allows to get first ready value out of number of alternatives. |
protected class |
AsyncProcess.ProcessWhen<I>
A utility when variant that fails process (using AsyncProcess.failure(Throwable) ) if promise is smashed or body
is smashed. |
class |
CloseableWrapper<FacetType extends ACloseable,WrappedType extends ACloseable>
This is a base class for closeables that built upon other closeable objects. |
protected class |
CloseableWrapper.InvalidatingWhen<I,R>
When that invalidates the stream in case of exception |
class |
Compensated
This a special return value for actions in some control constructs like Any . |
class |
CompensatedClosable
An utility subclass that closes closable that has been received. |
class |
Queue<T>
Object queue. |
class |
RunDispatcher
This is an utility class that is used for serveral control constructs. |
class |
Semaphore
Asynchronous semaphore service. |
class |
Seq<R>
A sequence control construct. |
class |
Serialized<T>
This class respresents action serialized over request queue. |
Uses of ExplicitSharing in net.sf.asyncobjects.util.callbacks |
---|
Classes in net.sf.asyncobjects.util.callbacks that implement ExplicitSharing | |
---|---|
class |
CallableAdapter<T>
This is an adapter for callable actions that allows to create ACallable instances using anonymous inner classes. |
class |
CallableAdapter.InternalCallableAdapter
An internal class that addapt Adapter calss to asynchronous interface. |
class |
ListenerAdapter<Event>
An adapter for listeners class |
class |
ListenerAdapter.InternalListenerAdapter
An internal class that addapt Adapter calss to asynchronous interface. |
class |
MapperAdapter<I,O>
Adapter for the AMapper interface. |
class |
MapperAdapter.InternalMapperAdapter
An internal class that addapt Adapter calss to asynchronous interface. |
class |
RunnableAdapter
A runnable adapter that allows using anonymouns inner classes for implementing the ARunnable interface. |
class |
RunnableAdapter.InternalRunnableAdapter
An internal class that addapt Adapter calss to asynchronous interface. |
Uses of ExplicitSharing in net.sf.asyncobjects.util.timer |
---|
Classes in net.sf.asyncobjects.util.timer that implement ExplicitSharing | |
---|---|
class |
TimerTaskAdapter
An adapter that helps to impelemnt time tasks. |
class |
TimerTaskAdapter.InternalTimerTask
Internal class that acutally implemetns interface |
class |
TimerWrapper
A timer wrapper. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |