public void stream()

in 3-extensions/protocol/dubbo-samples-triple/src/main/java/org/apache/dubbo/sample/tri/util/TriSampleClient.java [50:61]

• 12 lines of code
• 2 McCabe index (conditional complexity)

    public void stream() {
        LOGGER.info("{} Start bi streaming", clientName);
        final StreamObserver<GreeterRequest> request = greeter.greetStream(new StdoutStreamObserver<>("stream"));
        for (int i = 0; i < 10; i++) {
            LOGGER.info("{} Send stream request-> {}", clientName, i);
            request.onNext(GreeterRequest.newBuilder()
                    .setName("request")
                    .build());
        }
        LOGGER.info("{} Bi stream done", clientName);
        request.onCompleted();
    }