com.prosyst.mprm.backend.asyncstreaming

Interface AsyncDataSender

public interface AsyncDataSender

An instance of this interface is returned by the method AsyncStreamingService.openAsyncStream(String, String, AsyncDataReceiver) and provides methods for sending of data to the remote peer of the active async stream.

Method Summary

Modifier and Type	Method and Description
void	close() Closes this stream for sending.
void	close(java.lang.String errorMessage) Terminates this stream completely (both for sending and for receiving).
void	send(java.nio.ByteBuffer buffer) Sends a data chunk over this stream.
void	send(java.nio.ByteBuffer buffer, boolean lastOne) Sends a data chunk over this stream.

Method Detail

send

void send(java.nio.ByteBuffer buffer)
   throws java.io.IOException

Sends a data chunk over this stream. The data is send asynchronously, i.e. the method call return immediately and the actual sending is performed in background.

Parameters:

buffer - the data chunk which will be send over the stream

Throws:

java.io.IOException

send

void send(java.nio.ByteBuffer buffer,
          boolean lastOne)
   throws java.io.IOException

Sends a data chunk over this stream. The data is send asynchronously, i.e. the method call return immediately and the actual sending is performed in background.

Parameters:

buffer - the data chunk which will be send over the stream

lastOne - if true then this stream will be closed for sending.

Throws:

java.io.IOException

close

void close()

Closes this stream for sending. The stream can still be open for receiving of data, unless/until the corresponding AsyncDataReceiver.handleClose() method is called.

close

void close(java.lang.String errorMessage)

Terminates this stream completely (both for sending and for receiving).

Parameters:

errorMessage - The reson for abnormal termination of the stream.