Class OrcaOobUtil.OrcaReportingHelper.OrcaReportingState.OrcaReportingStream

    • Field Detail

      • stopwatch

        private final com.google.common.base.Stopwatch stopwatch
      • callHasResponded

        private boolean callHasResponded
    • Constructor Detail

      • OrcaReportingStream

        OrcaReportingStream​(io.grpc.Channel channel,
                            com.google.common.base.Stopwatch stopwatch)
    • Method Detail

      • start

        void start()
      • onMessage

        public void onMessage​(OrcaLoadReport response)
        Overrides:
        onMessage in class io.grpc.ClientCall.Listener<OrcaLoadReport>
      • onClose

        public void onClose​(io.grpc.Status status,
                            io.grpc.Metadata trailers)
        Overrides:
        onClose in class io.grpc.ClientCall.Listener<OrcaLoadReport>
      • handleStreamClosed

        void handleStreamClosed​(io.grpc.Status status)
      • cancel

        void cancel​(java.lang.String msg)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object