com.revolsys.parallel.channel

Interface ChannelInput<T>

All Superinterfaces:

Iterable<T>

All Known Subinterfaces:

SelectableChannelInput<T>

All Known Implementing Classes:

AbstractChannelInput, Channel

public interface ChannelInput<T>
extends Iterable<T>

Method Summary

Methods

Modifier and Type	Method and Description
T	read() Reads an Object from the Channel.
T	read(long timeout) Reads an Object from the Channel.
void	readConnect()
void	readDisconnect()

Methods inherited from interface java.lang.Iterable

iterator

Method Detail

read

T read()

Reads an Object from the Channel. This method also ensures only one of the readers can actually be reading at any time. All other readers are blocked until it completes the read.

Returns:

The object returned from the Channel.

read

T read(long timeout)

Reads an Object from the Channel. This method also ensures only one of the readers can actually be reading at any time. All other readers are blocked until it completes the read. If no data is available to be read after the timeout the method will return null.

Parameters:

timeout - The maximum time to wait in milliseconds.

Returns:

The object returned from the Channel.

readConnect

void readConnect()

readDisconnect

void readDisconnect()