Package io.grpc.stub

Class ClientCalls.CallToStreamObserverAdapter<ReqT>

java.lang.Object
io.grpc.stub.CallStreamObserver<ReqT>
io.grpc.stub.ClientCallStreamObserver<ReqT>
io.grpc.stub.ClientCalls.CallToStreamObserverAdapter<ReqT>
All Implemented Interfaces:
StreamObserver<ReqT>
Enclosing class:
ClientCalls

private static final class ClientCalls.CallToStreamObserverAdapter<ReqT> extends ClientCallStreamObserver<ReqT>
  • Field Details

    • frozen

      private boolean frozen
    • call

      private final ClientCall<ReqT,?> call
    • streamingResponse

      private final boolean streamingResponse
    • onReadyHandler

      private Runnable onReadyHandler
    • initialRequest

      private int initialRequest
    • autoRequestEnabled

      private boolean autoRequestEnabled
    • aborted

      private boolean aborted
    • completed

      private boolean completed
  • Constructor Details

    • CallToStreamObserverAdapter

      CallToStreamObserverAdapter(ClientCall<ReqT,?> call, boolean streamingResponse)
  • Method Details