Package | Description |
---|---|
net.i2p.client.streaming.impl |
Implementation of a TCP-like (reliable, authenticated, in order) set of sockets for
communicating over the IP-like (unreliable, unauthenticated, unordered) I2P
messages.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
ConnectionDataReceiver
Receive data from the MessageOutputStream, build a packet,
and send it through a connection.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
MessageOutputStream.flushAvailable(MessageOutputStream.DataReceiver target)
called whenever the engine wants to push more data to the
peer
|
(package private) void |
MessageOutputStream.flushAvailable(MessageOutputStream.DataReceiver target,
boolean blocking) |
Constructor and Description |
---|
MessageOutputStream(I2PAppContext ctx,
SimpleTimer2 timer,
MessageOutputStream.DataReceiver receiver,
int bufSize) |
MessageOutputStream(I2PAppContext ctx,
SimpleTimer2 timer,
MessageOutputStream.DataReceiver receiver,
int bufSize,
int passiveFlushDelay) |