@Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        final TriRpcStatus status = TriRpcStatus.INTERNAL.withCause(cause);
        LOGGER.warn(
                PROTOCOL_FAILED_SERIALIZE_TRIPLE,
                "",
                "",
                "Meet Exception on ClientResponseHandler, status code is: " + status.code,
                cause);
        transportListener.cancelByRemote(Http2Error.INTERNAL_ERROR.code());
        ctx.close();
    }
@Test
    void testExceptionCaught() {
        RuntimeException exception = new RuntimeException();
        handler.exceptionCaught(ctx, exception);
        Mockito.verify(ctx).close();
        Mockito.verify(transportListener).cancelByRemote(Http2Error.INTERNAL_ERROR.code());
    }