private void sendResponse(Response response) {
        try {
            ((GrpcConnection) this.currentConnection).sendResponse(response);
        } catch (Exception e) {
            LOGGER.error("[{}]Error to send ack response, ackId->{}", this.currentConnection.getConnectionId(),
                    response.getRequestId());
        }
    }
@Test
    void testBindRequestStreamOnNextParseException()
            throws NoSuchFieldException, IllegalAccessException, NoSuchMethodException, InvocationTargetException {
        BiRequestStreamGrpc.BiRequestStreamStub stub = mock(BiRequestStreamGrpc.BiRequestStreamStub.class);
        GrpcConnection grpcConnection = mock(GrpcConnection.class);
        when(stub.requestBiStream(any())).thenAnswer((Answer<StreamObserver<Payload>>) invocationOnMock -> {
            ((StreamObserver<Payload>) invocationOnMock.getArgument(0)).onNext(Payload.newBuilder().build());
            return null;
        });
        setCurrentConnection(grpcConnection, grpcClient);
        invokeBindRequestStream(grpcClient, stub, grpcConnection);
        verify(grpcConnection, never()).sendResponse(any(ErrorResponse.class));
    }