public void start()

in src/main/java/org/apache/skywalking/banyandb/v1/client/grpc/channel/ChannelManager.java [203:215]

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

        public void start(Listener<RESP> responseListener, Metadata headers) {
            super.start(
                    new ForwardingClientCallListener.SimpleForwardingClientCallListener<RESP>(responseListener) {
                        @Override
                        public void onClose(Status status, Metadata trailers) {
                            if (isNetworkError(status)) {
                                entry.needReconnect = true;
                            }
                            super.onClose(status, trailers);
                        }
                    },
                    headers);
        }