Dubbo3中CallStreamObserver与CancelableStreamObserver区别详解

在Dubbo3中，"org.apache.dubbo.rpc.protocol.tri.observer.CallStreamObserver"和"org.apache.dubbo.rpc.protocol.tri.CancelableStreamObserver"是两个不同的观察者接口，用于处理Tri（Dubbo的新传输协议）中的流式调用。\n\n"CallStreamObserver"接口是一个双向流观察者，用于处理双向流式调用，可以发送和接收多个数据。它包含了一系列方法，如"onNext()"用于发送数据，"onError()"用于处理错误，"onCompleted()"用于标记流结束等。\n\n"CancelableStreamObserver"接口是一个可取消的观察者，用于处理单向流式调用，只能发送或接收一个数据。它继承自"CallStreamObserver"接口，并额外添加了"cancel()"方法，用于取消流式调用。\n\n总结来说，"CallStreamObserver"用于处理双向流式调用，可以发送和接收多个数据，而"CancelableStreamObserver"用于处理单向流式调用，只能发送或接收一个数据，并且可以取消流式调用。