protected StreamObserver buildStreamObserver()

in src/main/java/org/apache/skywalking/banyandb/v1/client/MeasureBulkWriteProcessor.java [54:73]

• 17 lines of code
• 1 McCabe index (conditional complexity)

    protected StreamObserver<BanyandbMeasure.WriteRequest> buildStreamObserver(MeasureServiceGrpc.MeasureServiceStub stub,
                                                                               CompletableFuture<Void> batch) {
        return stub.write(new StreamObserver<BanyandbMeasure.WriteResponse>() {
            @Override
            public void onNext(BanyandbMeasure.WriteResponse writeResponse) {

            }

            @Override
            public void onError(Throwable t) {
                batch.completeExceptionally(t);
                log.error("Error occurs in flushing measures", t);
            }

            @Override
            public void onCompleted() {
                batch.complete(null);
            }
        });
    }