QueuedI2CPMessageReader
public class I2CPMessageReader
extends java.lang.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.修飾子とタイプ | クラス | 説明 |
---|---|---|
static interface |
I2CPMessageReader.I2CPMessageEventListener |
Defines the different events the reader produces while reading the stream
|
protected class |
I2CPMessageReader.I2CPMessageReaderRunner |
修飾子とタイプ | フィールド | 説明 |
---|---|---|
protected static java.util.concurrent.atomic.AtomicLong |
__readerId |
|
protected I2CPMessageReader.I2CPMessageEventListener |
_listener |
|
protected I2CPMessageReader.I2CPMessageReaderRunner |
_reader |
|
protected java.lang.Thread |
_readerThread |
修飾子 | コンストラクタ | 説明 |
---|---|---|
|
I2CPMessageReader(java.io.InputStream stream,
I2CPMessageReader.I2CPMessageEventListener lsnr) |
|
protected |
I2CPMessageReader(I2CPMessageReader.I2CPMessageEventListener lsnr) |
For internal extension only.
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
I2CPMessageReader.I2CPMessageEventListener |
getListener() |
|
void |
pauseReading() |
推奨されていません。
unused
|
void |
resumeReading() |
推奨されていません。
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 java.lang.Thread _readerThread
protected static final java.util.concurrent.atomic.AtomicLong __readerId
public I2CPMessageReader(java.io.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()