com.prosyst.mprm.backend.asyncstreaming

Interface AsyncDataReceiver

public interface AsyncDataReceiver

A call-back interface implemented by the application and supplied to the {@link AsyncStreamingService#openAsyncStream(String, String, AsyncDataReceiver) method call. Through this call back, the application receives the data send by the remote peer.

Method Summary

Modifier and Type	Method and Description
void	handleClose() Called when remote peer has finished sending its data over this stream.
void	handleClose(java.lang.String error) Called when the stream is interrupted abnormally.
void	handleData(java.nio.ByteBuffer buffer) Called when a new chunk of data is received from the remote peer.

Method Detail

handleData

void handleData(java.nio.ByteBuffer buffer)

Called when a new chunk of data is received from the remote peer.

Parameters:

buffer - the chunk of data

handleClose

void handleClose()

Called when remote peer has finished sending its data over this stream. After this method is called, there will be no more calls of {handleData(ByteBuffer) method. The other direction of the stream may still be active (unless/until) the application calls {@link AsyncDataSender#close()) method.

handleClose

void handleClose(java.lang.String error)

Called when the stream is interrupted abnormally. No more data can be sent or received over this stream.

Parameters:

error - the reason for abnormal stream closure.