| 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 | ConnectionDataReceiverReceive 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. |