class One2AnyImpl<T> extends java.lang.Object implements One2AnyChannel<T>, ChannelInternals<T>
Modifier and Type | Field and Description |
---|---|
private ChannelInternals<T> |
channel |
private Mutex |
readMutex
The mutex on which readers must synchronize
|
Constructor and Description |
---|
One2AnyImpl(ChannelInternals<T> _channel) |
Modifier and Type | Method and Description |
---|---|
void |
endRead() |
SharedChannelInput<T> |
in()
Returns the input end of the channel.
|
ChannelOutput<T> |
out()
Returns the output end of the channel.
|
T |
read() |
boolean |
readerDisable() |
boolean |
readerEnable(Alternative alt) |
boolean |
readerPending() |
void |
readerPoison(int strength) |
T |
startRead() |
void |
write(T obj) |
void |
writerPoison(int strength) |
private ChannelInternals<T> channel
private final Mutex readMutex
One2AnyImpl(ChannelInternals<T> _channel)
public SharedChannelInput<T> in()
One2AnyChannel
in
in interface One2AnyChannel<T>
public ChannelOutput<T> out()
One2AnyChannel
out
in interface One2AnyChannel<T>
public void endRead()
endRead
in interface ChannelInternals<T>
public T read()
read
in interface ChannelInternals<T>
public boolean readerDisable()
readerDisable
in interface ChannelInternals<T>
public boolean readerEnable(Alternative alt)
readerEnable
in interface ChannelInternals<T>
public boolean readerPending()
readerPending
in interface ChannelInternals<T>
public void readerPoison(int strength)
readerPoison
in interface ChannelInternals<T>
public T startRead()
startRead
in interface ChannelInternals<T>
public void write(T obj)
write
in interface ChannelInternals<T>
public void writerPoison(int strength)
writerPoison
in interface ChannelInternals<T>