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.I2CPMessageEventListenerDefines the different events the reader produces while reading the stream |
protected class | I2CPMessageReader.I2CPMessageReaderRunnerI2CPMessageReaderRunner. |
| Modifier and Type | Field and Description |
|---|---|
protected static AtomicLong | __readerId__readerId. |
protected I2CPMessageReader.I2CPMessageEventListener | _listener_listener. |
protected I2CPMessageReader.I2CPMessageReaderRunner | _reader_reader. |
protected Thread | _readerThread_readerThread. |
| Modifier | Constructor and Description |
|---|---|
protected | I2CPMessageReader(I2CPMessageReader.I2CPMessageEventListener lsnr)For internal extension only. |
| I2CPMessageReader(InputStream stream,
I2CPMessageReader.I2CPMessageEventListener lsnr)I2CPMessageReader. |
| Modifier and Type | Method and Description |
|---|---|
I2CPMessageReader.I2CPMessageEventListener | getListener() |
void | setListener(I2CPMessageReader.I2CPMessageEventListener lsnr)setListener. |
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)
lsnr - the lsnrpublic I2CPMessageReader(InputStream stream, I2CPMessageReader.I2CPMessageEventListener lsnr)
public I2CPMessageReader.I2CPMessageEventListener getListener()
public final void setListener(I2CPMessageReader.I2CPMessageEventListener lsnr)
public void startReading()
public void stopReading()