public void greetStream()

in 3-extensions/protocol/dubbo-samples-triple/src/main/java/org/apache/dubbo/sample/tri/pojo/TriPojoClient.java [74:82]

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

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