org.apache.dubbo.rpc.protocol.tri.stream

Interface Stream.Listener

All Known Subinterfaces:

ClientStream.Listener, ServerStream.Listener

All Known Implementing Classes:

AbstractServerCall, ReflectionAbstractServerCall, StubAbstractServerCall, TripleClientCall

Enclosing interface:

Stream

public static interface Stream.Listener

Register a Stream.Listener to receive inbound data from remote peer.

Method Summary

Modifier and Type	Method and Description
void	onCancelByRemote(TriRpcStatus status) Callback when receive cancel signal.
void	onMessage(byte[] message) Callback when receive message.

Method Detail

onMessage

void onMessage(byte[] message)

Callback when receive message. Note this method may be called many times if is a streaming .

Parameters:

message - message received from remote peer

onCancelByRemote

void onCancelByRemote(TriRpcStatus status)

Callback when receive cancel signal.

Parameters:

status - the cancel status