- action() - Method in class org.michailov.async.AsyncAgent
-
- action() - Method in class org.michailov.async.io.AsyncByteStreamReader
-
"action" function that reads bytes from the stream and writes them to the ring buffer.
- action() - Method in class org.michailov.async.io.AsyncByteStreamWriter
-
"action" function that reads bytes from the ring buffer and writes them to the stream.
- action() - Method in class org.michailov.async.io.AsyncCharDecoder
-
"action" function that reads bytes from the input byte ring buffer and writes chars to the output char ring buffer.
- action() - Method in class org.michailov.async.io.AsyncCharEncoder
-
"action" function that reads chars from the input char ring buffer and writes bytes to the output byte ring buffer.
- action() - Method in class org.michailov.async.io.AsyncLineJoiner
-
"action" function that reads chars from the input char ring buffer and writes lines to the output string ring buffer.
- action() - Method in class org.michailov.async.io.AsyncLineSplitter
-
"action" function that reads chars from the input char ring buffer and writes lines to the output string ring buffer.
- action() - Method in class org.michailov.async.io.AsyncRingBufferWatcher
-
"action" function that invokes the onAvailableToRead callback synchronously.
- action() - Method in class org.michailov.async.io.AsyncTextStreamReader
-
"action" function that gets executed as part of the apply loop.
- action() - Method in class org.michailov.async.io.AsyncTextStreamWriter
-
"action" function that gets executed as part of the apply loop.
- advanceReadPosition(int) - Method in class org.michailov.async.io.RingBuffer
-
This method must be called to indicate a successful read operation.
- advanceWritePosition(int) - Method in class org.michailov.async.io.RingBuffer
-
This method must be called to indicate a successful write operation.
- applyAsync() - Method in class org.michailov.async.AsyncAgent
-
- applyAsync(Predicate<S>, Function<S, R>, S) - Static method in class org.michailov.async.WhenReady
-
- applyAsync(Predicate<S>, Function<S, R>, S, AsyncOptions) - Static method in class org.michailov.async.WhenReady
-
- AsyncAgent - Class in org.michailov.async
-
Abstract functionality that encapsulates context in which
WhenReady
patterns are called.
- AsyncAgent(AsyncOptions) - Constructor for class org.michailov.async.AsyncAgent
-
Base constructor for derived classes to call.
- AsyncByteStreamReader - Class in org.michailov.async.io
-
Asynchronous byte reader over a plain old InputStream wrapped in an
EOFInputStream
.
- AsyncByteStreamReader(EOFInputStream, ByteRingBuffer, AsyncOptions) - Constructor for class org.michailov.async.io.AsyncByteStreamReader
-
Constructs a new AsyncByteStreamReader instance to read from the given InputStream
into the given
ByteRingBuffer
.
- AsyncByteStreamWriter - Class in org.michailov.async.io
-
Asynchronous byte writer over a plain old OutputStream.
- AsyncByteStreamWriter(OutputStream, ByteRingBuffer, AsyncOptions) - Constructor for class org.michailov.async.io.AsyncByteStreamWriter
-
Constructs a new AsyncByteStreamWriter instance to write to the given OutputStream
from the given
ByteRingBuffer
.
- AsyncCharDecoder - Class in org.michailov.async.io
-
Asynchronous decoder of bytes into chars.
- AsyncCharDecoder(ByteRingBuffer, CharRingBuffer, CharsetAsyncOptions) - Constructor for class org.michailov.async.io.AsyncCharDecoder
-
Constructs an AsyncCharDecoder instance over the given ring buffers.
- AsyncCharEncoder - Class in org.michailov.async.io
-
Asynchronous encoder of chars into bytes.
- AsyncCharEncoder(CharRingBuffer, ByteRingBuffer, CharsetAsyncOptions) - Constructor for class org.michailov.async.io.AsyncCharEncoder
-
Constructs an AsyncCharEncoder instance over the given ring buffers.
- AsyncException - Exception in org.michailov.async
-
This unchecked exception type should be used by predicates and functions to report checked exceptions to the
WhenReady
framework is not possible from lambdas.
- AsyncException() - Constructor for exception org.michailov.async.AsyncException
-
- AsyncException(String) - Constructor for exception org.michailov.async.AsyncException
-
- AsyncException(Throwable) - Constructor for exception org.michailov.async.AsyncException
-
- AsyncException(String, Throwable) - Constructor for exception org.michailov.async.AsyncException
-
- AsyncException(String, Throwable, boolean, boolean) - Constructor for exception org.michailov.async.AsyncException
-
- AsyncLineJoiner - Class in org.michailov.async.io
-
Asynchronous joiner of discrete lines into a sequence of chars.
- AsyncLineJoiner(StringRingBuffer, CharRingBuffer, LineAsyncOptions) - Constructor for class org.michailov.async.io.AsyncLineJoiner
-
Constructs an AsyncLineJoiner instance over the given ring buffers.
- AsyncLineSplitter - Class in org.michailov.async.io
-
Asynchronous splitter of chars into lines.
- AsyncLineSplitter(CharRingBuffer, StringRingBuffer, LineAsyncOptions) - Constructor for class org.michailov.async.io.AsyncLineSplitter
-
Constructs an AsyncLineSpliter instance over the given ring buffers.
- AsyncOptions - Class in org.michailov.async
-
Common options that control the execution of async methods from this package.
- AsyncOptions() - Constructor for class org.michailov.async.AsyncOptions
-
- AsyncRingBufferWatcher<TRingBuffer extends RingBuffer> - Class in org.michailov.async.io
-
- AsyncRingBufferWatcher(TRingBuffer, Consumer<TRingBuffer>, AsyncOptions) - Constructor for class org.michailov.async.io.AsyncRingBufferWatcher
-
Constructs an AsyncCharDecoder instance over the given ring buffers.
- AsyncTextStreamReader - Class in org.michailov.async.io
-
Asynchronous text line reader over a plain old InputStream wrapped in an
EOFInputStream
.
- AsyncTextStreamReader(EOFInputStream, TextStreamAsyncOptions) - Constructor for class org.michailov.async.io.AsyncTextStreamReader
-
Constructs a new AsyncTextStreamReader instance to read from the given InputStream.
- AsyncTextStreamReader(EOFInputStream, Consumer<StringRingBuffer>, TextStreamAsyncOptions) - Constructor for class org.michailov.async.io.AsyncTextStreamReader
-
Constructs a new AsyncTextStreamReader instance to read from the given InputStream.
- AsyncTextStreamReader(EOFInputStream, ByteRingBuffer, CharRingBuffer, StringRingBuffer, Consumer<StringRingBuffer>, TextStreamAsyncOptions) - Constructor for class org.michailov.async.io.AsyncTextStreamReader
-
Constructs a new AsyncTextStreamReader instance to read from the given InputStream.
- AsyncTextStreamWriter - Class in org.michailov.async.io
-
Asynchronous text line writer over a plain old OutputStream.
- AsyncTextStreamWriter(OutputStream, TextStreamAsyncOptions) - Constructor for class org.michailov.async.io.AsyncTextStreamWriter
-
Constructs a new AsyncTextStreamWriter instance to write to the given OutputStream.
- AsyncTextStreamWriter(OutputStream, StringRingBuffer, CharRingBuffer, ByteRingBuffer, TextStreamAsyncOptions) - Constructor for class org.michailov.async.io.AsyncTextStreamWriter
-
Constructs a new AsyncTextStreamWriter instance to write into the given OutputStream.
- available() - Method in class org.michailov.async.io.EOFInputStream
-
- getAsyncStringRingBufferWatcher() - Method in class org.michailov.async.io.AsyncTextStreamReader
-
- getAvailableToRead() - Method in class org.michailov.async.io.RingBuffer
-
Gets the count of items that are available to be read.
- getAvailableToReadStraight() - Method in class org.michailov.async.io.RingBuffer
-
Gets the count of items that are available to be read at once.
- getAvailableToWrite() - Method in class org.michailov.async.io.RingBuffer
-
Gets the count of items that are available to be written.
- getAvailableToWriteStraight() - Method in class org.michailov.async.io.RingBuffer
-
Gets the count of items that are available to be written at once.
- getBuffer() - Method in class org.michailov.async.io.ByteRingBuffer
-
Gets the underlying byte[].
- getBuffer() - Method in class org.michailov.async.io.CharRingBuffer
-
Gets the underlying char[].
- getBuffer() - Method in class org.michailov.async.io.StringRingBuffer
-
Gets the underlying String[].
- getBufferLength() - Method in class org.michailov.async.io.RingBuffer
-
Gets the length of the underlying buffer.
- getByteRingBuffer() - Method in class org.michailov.async.io.AsyncByteStreamReader
-
Returns the attached ring buffer where bytes will be written.
- getByteRingBuffer() - Method in class org.michailov.async.io.AsyncByteStreamWriter
-
Returns the attached ring buffer where bytes will be read from.
- getByteRingBuffer() - Method in class org.michailov.async.io.AsyncCharDecoder
-
Returns the attached byte ring buffer from where bytes will be read.
- getByteRingBuffer() - Method in class org.michailov.async.io.AsyncCharEncoder
-
Returns the attached byte ring buffer where bytes will be written.
- getCharRingBuffer() - Method in class org.michailov.async.io.AsyncCharDecoder
-
Returns the attached char ring buffer where chars will be written.
- getCharRingBuffer() - Method in class org.michailov.async.io.AsyncCharEncoder
-
Returns the attached char ring buffer from where chars will be read.
- getCharRingBuffer() - Method in class org.michailov.async.io.AsyncLineJoiner
-
Returns the attached char ring buffer from where chars will be written.
- getCharRingBuffer() - Method in class org.michailov.async.io.AsyncLineSplitter
-
Returns the attached char ring buffer from where chars will be read from.
- getInputStream() - Method in class org.michailov.async.io.AsyncByteStreamReader
-
Returns the underlying InputStream.
- getLogger() - Static method in class org.michailov.async.Logger
-
Gets the shared instance.
- getOutputStream() - Method in class org.michailov.async.io.AsyncByteStreamWriter
-
Returns the underlying OutputStream.
- getReadPosition() - Method in class org.michailov.async.io.RingBuffer
-
Gets the current virtual read position.
- getRingBuffer() - Method in class org.michailov.async.io.AsyncRingBufferWatcher
-
Returns the watched ring buffer.
- getStringRingBuffer() - Method in class org.michailov.async.io.AsyncLineJoiner
-
Returns the attached string ring buffer where lines will be read from.
- getStringRingBuffer() - Method in class org.michailov.async.io.AsyncLineSplitter
-
Returns the attached string ring buffer where lines will be written.
- getStringRingBuffer() - Method in class org.michailov.async.io.AsyncTextStreamReader
-
- getStringRingBuffer() - Method in class org.michailov.async.io.AsyncTextStreamWriter
-
- getTotalReadCount() - Method in class org.michailov.async.io.RingBuffer
-
Gets the total count of read items.
- getTotalWriteCount() - Method in class org.michailov.async.io.RingBuffer
-
Gets the total count of written items.
- getWritePosition() - Method in class org.michailov.async.io.RingBuffer
-
Gets the current virtual write position.
- isEmpty() - Method in class org.michailov.async.io.AsyncTextStreamWriter
-
Checks whether all the underlying ring buffers are empty.
- isEOF() - Method in class org.michailov.async.io.AsyncByteStreamReader
-
Checks whether this reader has reached EOF of the stream.
- isEOF() - Method in class org.michailov.async.io.AsyncByteStreamWriter
-
Checks whether this writer has reached EOF of the byte ring buffer.
- isEOF() - Method in class org.michailov.async.io.AsyncCharDecoder
-
Checks whether this decoder has reached EOF of the input byte ring buffer.
- isEOF() - Method in class org.michailov.async.io.AsyncCharEncoder
-
Checks whether this decoder has reached EOF of the input char ring buffer.
- isEOF() - Method in class org.michailov.async.io.AsyncLineJoiner
-
Checks whether this line joiner has reached EOF of the input string ring buffer.
- isEOF() - Method in class org.michailov.async.io.AsyncLineSplitter
-
Checks whether this line splitter has reached EOF of the input char ring buffer.
- isEOF() - Method in class org.michailov.async.io.AsyncRingBufferWatcher
-
Checks whether this watcher has reached EOF of the watched ring buffer.
- isEOF() - Method in class org.michailov.async.io.AsyncTextStreamReader
-
Checks whether this text stream reader has reached EOF.
- isEOF() - Method in class org.michailov.async.io.AsyncTextStreamWriter
-
Checks whether this text stream writer has reached EOF.
- isEOF() - Method in class org.michailov.async.io.RingBuffer
-
Gets the EOF state of this ring buffer.
- isIdle() - Method in class org.michailov.async.AsyncAgent
-
Checks whether this AsyncAgent is idle, i.e.
- read() - Method in class org.michailov.async.io.ByteRingBuffer
-
Reads the byte at the virtual read position, and advances the virtual read position by 1.
- read() - Method in class org.michailov.async.io.CharRingBuffer
-
Reads the char at the virtual read position, and advances the virtual read position by 1.
- read() - Method in class org.michailov.async.io.EOFInputStream
-
- read(byte[], int, int) - Method in class org.michailov.async.io.EOFInputStream
-
- read() - Method in class org.michailov.async.io.StringRingBuffer
-
Reads the String at the virtual read position, and advances the virtual read position by 1.
- ready() - Method in class org.michailov.async.AsyncAgent
-
The '
ready' predicate passed to
completeAsync(java.util.function.Predicate<S>, R, S)
,
applyAsync(java.util.function.Predicate<S>, java.util.function.Function<S, R>, S)
, or
startApplyLoopAsync(java.util.function.Predicate<S>, java.util.function.Predicate<S>, java.util.function.Function<S, R>, S)
.
- ready() - Method in class org.michailov.async.io.AsyncByteStreamReader
-
"ready" predicate that returns true when bytes can be read from the stream and written to the ring buffer without blocking.
- ready() - Method in class org.michailov.async.io.AsyncByteStreamWriter
-
"ready" predicate that returns true when bytes can be read from the ring buffer without blocking.
- ready() - Method in class org.michailov.async.io.AsyncCharDecoder
-
"ready" predicate that returns true when bytes can be read from the input
byte ring buffer and chars can be written to the output char ring buffer without blocking.
- ready() - Method in class org.michailov.async.io.AsyncCharEncoder
-
"ready" predicate that returns true when chars can be read from the input
char ring buffer and bytes can be written to the output byte ring buffer without blocking.
- ready() - Method in class org.michailov.async.io.AsyncLineJoiner
-
"ready" predicate that returns true when lines can be read from the input
string ring buffer and chars can be written to the output char ring buffer without blocking.
- ready() - Method in class org.michailov.async.io.AsyncLineSplitter
-
"ready" predicate that returns true when chars can be read from the input
char ring buffer and lines can be written to the output string ring buffer without blocking.
- ready() - Method in class org.michailov.async.io.AsyncRingBufferWatcher
-
"ready" predicate that returns true when items can be read from the watched ring buffer.
- ready() - Method in class org.michailov.async.io.AsyncTextStreamReader
-
"ready" predicate that returns true when lines can be read from the string ring buffer.
- ready() - Method in class org.michailov.async.io.AsyncTextStreamWriter
-
"ready" predicate that returns true when lines can be written to the string ring buffer.
- RingBuffer - Class in org.michailov.async.io
-
This class defines an abstract ring buffer functionality where a virtual read position
and a virtual write position chase each other around a buffer length.
- RingBuffer(int) - Constructor for class org.michailov.async.io.RingBuffer
-
Constructor to be called from concrete implementations.