class Any2OneImpl<T> extends java.lang.Object implements ChannelInternals<T>, Any2OneChannel<T>
Modifier and Type | Field and Description |
---|---|
private ChannelInternals<T> |
channel |
private java.lang.Object |
writeMonitor |
Constructor and Description |
---|
Any2OneImpl(ChannelInternals<T> _channel) |
Modifier and Type | Method and Description |
---|---|
void |
endRead() |
AltingChannelInput<T> |
in()
Returns the input end of the channel.
|
SharedChannelOutput<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 java.lang.Object writeMonitor
Any2OneImpl(ChannelInternals<T> _channel)
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>
public AltingChannelInput<T> in()
Any2OneChannel
in
in interface Any2OneChannel<T>
public SharedChannelOutput<T> out()
Any2OneChannel
out
in interface Any2OneChannel<T>