程序包 org.apache.dubbo.common.stream

接口 StreamObserver<T>

  • 类型参数:
    T - type of message
    public interface StreamObserver<T>
    StreamObserver is a common streaming API. It is an observer for receiving messages. Implementations are NOT required to be thread-safe.

    • 方法详细资料

      • onNext

        void onNext​(T data)
        onNext
        参数:
        data - to process

      • onError

        void onError​(Throwable throwable)
        onError
        参数:
        throwable - error

      • onCompleted

        void onCompleted()
        onCompleted