QueuedI2CPMessageReader
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 | Description |
---|---|---|
static interface |
I2CPMessageReader.I2CPMessageEventListener |
Defines the different events the reader produces while reading the stream
|
protected class |
I2CPMessageReader.I2CPMessageReaderRunner |
Modifier and Type | Field | Description |
---|---|---|
protected static AtomicLong |
__readerId |
|
protected I2CPMessageReader.I2CPMessageEventListener |
_listener |
|
protected I2CPMessageReader.I2CPMessageReaderRunner |
_reader |
|
protected Thread |
_readerThread |
Modifier | Constructor | Description |
---|---|---|
|
I2CPMessageReader(InputStream stream,
I2CPMessageReader.I2CPMessageEventListener lsnr) |
|
protected |
I2CPMessageReader(I2CPMessageReader.I2CPMessageEventListener lsnr) |
For internal extension only.
|
Modifier and Type | Method | Description |
---|---|---|
I2CPMessageReader.I2CPMessageEventListener |
getListener() |
|
void |
pauseReading() |
Deprecated.
unused
|
void |
resumeReading() |
Deprecated.
unused
|
void |
setListener(I2CPMessageReader.I2CPMessageEventListener lsnr) |
|
void |
startReading() |
Instruct the reader to begin reading messages off the stream
|
void |
stopReading() |
Cancel reading.
|
protected I2CPMessageReader.I2CPMessageEventListener _listener
protected I2CPMessageReader.I2CPMessageReaderRunner _reader
protected Thread _readerThread
protected static final AtomicLong __readerId
public I2CPMessageReader(InputStream stream, I2CPMessageReader.I2CPMessageEventListener lsnr)
protected I2CPMessageReader(I2CPMessageReader.I2CPMessageEventListener lsnr)
public void setListener(I2CPMessageReader.I2CPMessageEventListener lsnr)
public I2CPMessageReader.I2CPMessageEventListener getListener()
public void startReading()
@Deprecated public void pauseReading()
@Deprecated public void resumeReading()
public void stopReading()