Constructor Detail

• QueuedI2CPMessageReader

  public QueuedI2CPMessageReader(I2CPMessageQueue in,
                                 I2CPMessageReader.I2CPMessageEventListener lsnr)

  Creates a new instance of this QueuedMessageReader and registers with the shared dispatcher. Call startReading() to begin.

Method Detail

• processOnce

  boolean processOnce()

  Non-blocking poll + dispatch. Called by the shared dispatcher thread.

  Returns:

  true if a message was processed

• startReading

  public void startReading()

  Register with the shared dispatcher.

  Overrides:

  startReading in class I2CPMessageReader

• stopReading

  public void stopReading()

  Unregister from the shared dispatcher.

  Overrides:

  stopReading in class I2CPMessageReader