class ClientWriterRunner extends Object implements Runnable
Constructor and Description |
---|
ClientWriterRunner(RouterContext context,
ClientConnectionRunner runner) |
Modifier and Type | Method and Description |
---|---|
void |
addMessage(I2CPMessage msg)
Add this message to the writer's queue
Nonblocking, throws exception if queue is full
|
void |
run() |
void |
stopWriting()
No more messages - dont even try to send what we have
|
public ClientWriterRunner(RouterContext context, ClientConnectionRunner runner)
public void addMessage(I2CPMessage msg) throws I2CPMessageException
I2CPMessageException
public void stopWriting()