private void onRstStreamRead(int streamId, long errorCode) {
    NettyClientStream.TransportState stream = clientStream(connection().stream(streamId));
    if (stream != null) {
      Status status = GrpcUtil.Http2Error.statusForCode((int) errorCode)
          .augmentDescription("Received Rst Stream");
      stream.transportReportStatus(
          status,
          errorCode == Http2Error.REFUSED_STREAM.code()
              ? RpcProgress.REFUSED : RpcProgress.PROCESSED,
          false /*stop delivery*/,
          new Metadata());
      if (keepAliveManager != null) {
        keepAliveManager.onDataReceived();
      }
    }
  }
private void onRstStreamRead ( int streamId , long errorCode ) { NettyClientStream . TransportState stream = clientStream ( connection ( ) . stream ( streamId ) ) ; if ( stream != null ) { Status status = GrpcUtil . Http2Error . statusForCode ( ( int ) errorCode ) . augmentDescription ( "Received Rst Stream" ) ; stream . transportReportStatus ( status , errorCode == Http2Error . REFUSED_STREAM . code ( ) ? RpcProgress . REFUSED : RpcProgress . PROCESSED , false , new Metadata ( ) ) ; if ( keepAliveManager != null ) { keepAliveManager . onDataReceived ( ) ; } } }
Handler for an inbound HTTP/2 RST_STREAM frame, terminating a stream.