Packages that use MessageOutputStream.DataReceiver
Package
Description
Implementation of a TCP-like (reliable, authenticated, in order) set of sockets for communicating over the IP-like (unreliable, unauthenticated, unordered) I2P messages.
Uses of MessageOutputStream.DataReceiver in net.i2p.client.streaming.impl
Classes in net.i2p.client.streaming.impl that implement MessageOutputStream.DataReceiverModifier and TypeClassDescription(package private) classReceive data from the MessageOutputStream, build a packet, and send it through a connection.Fields in net.i2p.client.streaming.impl declared as MessageOutputStream.DataReceiverModifier and TypeFieldDescriptionprivate final MessageOutputStream.DataReceiverMessageOutputStream._dataReceiverThe connection receiving the data.Methods in net.i2p.client.streaming.impl with parameters of type MessageOutputStream.DataReceiverModifier and TypeMethodDescription(package private) voidMessageOutputStream.flushAvailable(MessageOutputStream.DataReceiver target) Convenience overload variant with blocking flush.(package private) voidMessageOutputStream.flushAvailable(MessageOutputStream.DataReceiver target, boolean blocking) Attempts to flush buffered data to the target DataReceiver, optionally blocking until accepted.Constructors in net.i2p.client.streaming.impl with parameters of type MessageOutputStream.DataReceiverModifierConstructorDescriptionMessageOutputStream(I2PAppContext ctx, SimpleTimer2 timer, MessageOutputStream.DataReceiver receiver, int bufSize, int initBufSize) Stream with default passive flush delay.MessageOutputStream(I2PAppContext ctx, SimpleTimer2 timer, MessageOutputStream.DataReceiver receiver, int bufSize, int initBufSize, int passiveFlushDelay) Stream with specified passive flush delay.