| 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)
Convenience overload variant with blocking flush.
|
(package private) void |
MessageOutputStream.flushAvailable(MessageOutputStream.DataReceiver target,
boolean blocking)
Attempts to flush buffered data to the target DataReceiver,
optionally blocking until accepted.
|
| Constructor and Description |
|---|
MessageOutputStream(I2PAppContext ctx,
SimpleTimer2 timer,
MessageOutputStream.DataReceiver receiver,
int bufSize,
int initBufSize)
Constructs the stream with default passive flush delay.
|
MessageOutputStream(I2PAppContext ctx,
SimpleTimer2 timer,
MessageOutputStream.DataReceiver receiver,
int bufSize,
int initBufSize,
int passiveFlushDelay)
Constructs the stream with specified passive flush delay.
|