class One2AnyIntImpl extends java.lang.Object implements One2AnyChannelInt, ChannelInternalsInt
| Modifier and Type | Field and Description |
|---|---|
private ChannelInternalsInt |
channel |
private Mutex |
readMutex
The mutex on which readers must synchronize
|
| Constructor and Description |
|---|
One2AnyIntImpl(ChannelInternalsInt _channel) |
| Modifier and Type | Method and Description |
|---|---|
void |
endRead() |
SharedChannelInputInt |
in()
Returns the input end of the channel.
|
ChannelOutputInt |
out()
Returns the output end of the channel.
|
int |
read() |
boolean |
readerDisable() |
boolean |
readerEnable(Alternative alt) |
boolean |
readerPending() |
void |
readerPoison(int strength) |
int |
startRead() |
void |
write(int n) |
void |
writerPoison(int strength) |
private ChannelInternalsInt channel
private final Mutex readMutex
One2AnyIntImpl(ChannelInternalsInt _channel)
public SharedChannelInputInt in()
One2AnyChannelIntin in interface One2AnyChannelIntpublic ChannelOutputInt out()
One2AnyChannelIntout in interface One2AnyChannelIntpublic void endRead()
endRead in interface ChannelInternalsIntpublic int read()
read in interface ChannelInternalsIntpublic boolean readerDisable()
readerDisable in interface ChannelInternalsIntpublic boolean readerEnable(Alternative alt)
readerEnable in interface ChannelInternalsIntpublic boolean readerPending()
readerPending in interface ChannelInternalsIntpublic void readerPoison(int strength)
readerPoison in interface ChannelInternalsIntpublic int startRead()
startRead in interface ChannelInternalsIntpublic void write(int n)
write in interface ChannelInternalsIntpublic void writerPoison(int strength)
writerPoison in interface ChannelInternalsInt