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

接口 ClientStream.Listener

所有超级接口:

Stream.Listener

所有已知实现类:

TripleClientCall

封闭接口:

ClientStream

public static interface ClientStream.Listener
extends Stream.Listener

方法概要

限定符和类型	方法和说明
default void	onComplete(TriRpcStatus status, Map<String,Object> attachments) Callback when stream completed.
default void	onComplete(TriRpcStatus status, Map<String,Object> attachments, Map<String,String> reserved, boolean isReturnTriException) Callback when request completed.
void	onStart() Callback when stream started.

从接口继承的方法 org.apache.dubbo.rpc.protocol.tri.stream.Stream.Listener

onCancelByRemote, onMessage

方法详细资料

onStart

void onStart()

Callback when stream started.

onComplete

default void onComplete(TriRpcStatus status,
                        Map<String,Object> attachments)

Callback when stream completed.

参数:

attachments - received from remote peer

onComplete

default void onComplete(TriRpcStatus status,
                        Map<String,Object> attachments,
                        Map<String,String> reserved,
                        boolean isReturnTriException)

Callback when request completed.

参数:

status - response status

attachments - attachments received from remote peer

reserved - triple protocol reserved data