Modifier and Type | Field and Description |
---|---|
private java.util.ArrayList |
incomingEnrolledBarriers
This is the list of barrier server ends that this Link has received an enroll for.
|
private java.io.DataInputStream |
inputStream
The input stream receiving messages from the opposite remote node
|
private ChannelOutput |
toTxProcess
This is the channel connected to the Link's TX process.
|
Constructor and Description |
---|
RxLoop(ChannelOutput out,
java.io.DataInputStream stream)
Constructor for the RX part of the Link
|
Modifier and Type | Method and Description |
---|---|
void |
run()
The point here is to try and deal with any message that may come into the Node.
|
private final ChannelOutput toTxProcess
private final java.io.DataInputStream inputStream
private final java.util.ArrayList incomingEnrolledBarriers
RxLoop(ChannelOutput out, java.io.DataInputStream stream)
out
- The Channel connected to the TX part of the Linkstream
- The input stream used to receive messages uponpublic void run()