public class StreamTransmitter extends MessageDecoder
This implementation is limited to sending from a fixed-size input array. The protocol permits continuous transmission, but this class is not intended to implement that.
Connection.ConnectionListener
Modifier and Type | Field and Description |
---|---|
(package private) int |
bufferSize |
(package private) int[] |
bytes |
(package private) Connection |
connection |
(package private) int |
destStreamID |
(package private) NodeID |
far |
(package private) NodeID |
here |
(package private) int |
nextIndex |
(package private) int |
sourceStreamID |
Constructor and Description |
---|
StreamTransmitter(NodeID here,
NodeID far,
int bufferSize,
int[] bytes,
Connection c) |
Modifier and Type | Method and Description |
---|---|
void |
handleStreamDataProceed(StreamDataProceedMessage msg,
Connection sender)
Handle "Stream Data Proceed" message
|
void |
handleStreamInitReply(StreamInitReplyMessage msg,
Connection sender)
Handle "Stream Init Reply" message
|
(package private) void |
sendNext() |
defaultHandler, handleConsumerIdentified, handleDatagram, handleDatagramAcknowledged, handleDatagramRejected, handleIdentifyConsumers, handleIdentifyEvents, handleIdentifyProducers, handleInitializationComplete, handleLearnEvent, handleOptionalIntRejected, handleProducerConsumerEventReport, handleProducerIdentified, handleProtocolIdentificationReply, handleProtocolIdentificationRequest, handleSimpleNodeIdentInfoReply, handleSimpleNodeIdentInfoRequest, handleStreamDataComplete, handleStreamDataSend, handleStreamInitRequest, handleVerifiedNodeIDNumber, handleVerifyNodeIDNumber, put
registerStartNotification
NodeID here
NodeID far
int bufferSize
int[] bytes
Connection connection
int nextIndex
int destStreamID
int sourceStreamID
public StreamTransmitter(NodeID here, NodeID far, int bufferSize, int[] bytes, Connection c)
public void handleStreamInitReply(StreamInitReplyMessage msg, Connection sender)
handleStreamInitReply
in class MessageDecoder
void sendNext()
public void handleStreamDataProceed(StreamDataProceedMessage msg, Connection sender)
handleStreamDataProceed
in class MessageDecoder
Information on copyright, trademarks and licenses is linked here.
Site hosted by: