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 |
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()