Writes the given message to the destination. If the destination does not have space, the write blocks until space is freed up in the destination. @pa

Create a {@link ChannelAction} for the given {@link Channel} with a given {@link Consumer} action that is going to be executed for each message in the

Closes the channel. Read and write operation on a closed channel would throw a {@link ClosedChannelException}

Reads the next message from the source. If there are no elements in the source, the read blocks until an element is available. If the source declared

Returns a copy of the message that should be stored in the in-memory data structure of the {@link Channel}. @param message The message to store in th

Convenience method to create a new {@link Selector} from the given set of {@link ChannelAction}s. @param actions The list of {@link ChannelAction}s t

Gets the next message for this thread from the underlying channel. If no message is available, this calls blocks until a new message is read in this t

Tries to read a message from the source. If there is no message, the method will return {@literal null}. @return The next message from the source if

The source can be read from. It does not necessarily means the read will succeed as it can get blocked or timeout, but it means that the source still

Returns a unique identifier for the {@link Channel}. @return A unique identifier for this {@link Channel}

Tries to write a message to the destination. If the destination does not have free space, the call returns immediately with {@literal false}. @param

Perform an action over the messages as received in the current thread from the channel. This method will not propagate the {@link NoSuchChannelElement

Runs an loop over all the channels and executes the action associated with that channel as and when a message is received on that channel. The loop br

For internal uses only . Register an {@link AfterWriteAction} to this {@link Channel}.

Remove is unsupported operation for a channel. This always throws an {@link UnsupportedOperationException}. @throws UnsupportedOperationException Alw

Waits for a message to be recieved on any of the channels associated with the {@link ChannelAction}s of this {@link Selector} and execute the action c

The destination allows write to happen. It does not necessarily means the write will succeed, it can block or timeout if there is no space, but if spa

Available slots in the channel. This is the difference between the capacity and the number of messages already in the channel. @return The number of

Checks if the channel has been closed. @return {@literal true}, if the channel has been closed, {@literal false} otherwise.

Mark the iterator as done (i.e., the underlying channel has been closed).

Creates a new {@link Selector} from the given set of {@link ChannelAction}s. @param actions The list of {@link ChannelAction}s that this {@link Selec

Execute an action after the given duration in a different thread. @param duration The duration of time @param unit The unit that is associated wi

Returns {@literal true} if the parent channel has not been closed, {@literal false} otherwise. @return {@literal true} if the parent channel has not

Returns {@literal true} in case the channel is open, else return {@literal false} @return {@literal true} if the channel has been open, {@literal fal

Create a generic {@link BufferedChannel} of the given capacity. It uses {@link KryoCopier} to copy the messages to the channel. @param type The c

Returns a new {@link Timer} instance which sends the current time on it's {@link Channel} once the timer expires. @param duration The duration after

Runs an loop over all the channels and executes the action associated with that channel as and when a message is received on that channel. When no mes

Closes the timer. Anu subsequent operation on the timer would throw a {@link ClosedChannelException}.

Runs the give action for each of the remaining messages that are read in this thread from the underlying channel, until the channel is closed. When th

The capacity of this {@link BufferedChannel}. Capacity is the number of messages that can be inserted into the channel without a read before the write

Run a routine on JaCh's executor.

Create a {@link BufferedChannel} that stores strings with the given capacity. It uses {@link RefCopier} to copy the messages to the channel. @param c

Reads the next message from the channel. If the channel is currently empty, the thread blocks until a message is available for reading. @throws NoSuc

Resets the duration of the timer to the new duration. @param duration The new duration for the {@link Timer} @param unit The unit corresponding t

Resets the tick interval of this ticker to the new interval. Subsequent events on this ticker will occur after the given interval. @param duration Th

{@link Spliterator} is not supported for a {@link Channel}. It will throw a {@link UnsupportedOperationException}. @see Channel#spliterator()

Stops the {@link Ticker} from sending further events. This method also cleans up existing resources held by this {@link Ticker} instance. Any subseque

Writes a non-null message to the channel. If the channel does not have enough space to write the message, the thread is blocked until space is availab

Initializes a {@link KryoCopier} with default instance of Kryo and Serializer.

Returns a {@link Channel} which will send the current time after the given duration expires. @param duration The duration after which to send the eve

Returns {@literal true} if the channel can be read. @return {@literal true} if the channel can be read, else {@literal false}.

Returns {@literal true} if the channel can be written to. @return {@literal true} if the channel can be written to, else {@literal false}.

Closes this channel. On closure of this channel, all the threads that are stuck in {@link #read()} or {@link #write(Object)} are interrupted. The iter

@see Copier#copyOf(Object)

@see Copier#copyOf(Object)

Returns the type of the element that is stored in this {@link Channel} @return The concrete class of type T that is stored in this {@link Channel}.

@see Channel#getDataType()

Returns a unique id for this {@link Channel}. @return A unique id for this {@link Channel}.

Returns an {@link Iterator} to iterate over the channel. The iterator is a blocking iterator. If no elements are present in the channel the iterators

Create a {@link BufferedChannel} that stores integers with the given capacity. It uses {@link RefCopier} to copy the messages to the channel. @param