public class I2CPMessageReader extends Object
I2CPMessageHandler) and passes out events to a registered
listener, where events are either messages being received, exceptions being
thrown, or the connection being closed. Applications should use this rather
than read from the stream themselves.| Modifier and Type | Class and Description |
|---|---|
static interface |
I2CPMessageReader.I2CPMessageEventListener
Defines the different events the reader produces while reading the stream
|
protected class |
I2CPMessageReader.I2CPMessageReaderRunner |
| Modifier and Type | Field and Description |
|---|---|
protected static AtomicLong |
__readerId |
protected I2CPMessageReader.I2CPMessageEventListener |
_listener |
protected I2CPMessageReader.I2CPMessageReaderRunner |
_reader |
protected Thread |
_readerThread |
| Modifier | Constructor and Description |
|---|---|
protected |
I2CPMessageReader(I2CPMessageReader.I2CPMessageEventListener lsnr)
For internal extension only.
|
|
I2CPMessageReader(InputStream stream,
I2CPMessageReader.I2CPMessageEventListener lsnr) |
| Modifier and Type | Method and Description |
|---|---|
I2CPMessageReader.I2CPMessageEventListener |
getListener() |
void |
setListener(I2CPMessageReader.I2CPMessageEventListener lsnr) |
void |
startReading()
Instruct the reader to begin reading messages off the stream
|
void |
stopReading()
Cancel reading.
|
protected static final AtomicLong __readerId
protected I2CPMessageReader.I2CPMessageEventListener _listener
protected I2CPMessageReader.I2CPMessageReaderRunner _reader
protected Thread _readerThread
protected I2CPMessageReader(I2CPMessageReader.I2CPMessageEventListener lsnr)
public I2CPMessageReader(InputStream stream, I2CPMessageReader.I2CPMessageEventListener lsnr)
public I2CPMessageReader.I2CPMessageEventListener getListener()
public void setListener(I2CPMessageReader.I2CPMessageEventListener lsnr)
public void startReading()
public void stopReading()