@ParameterizedTest
    @ArgumentsSource(ClientAndProtocolProvider.class)
    void testTimeoutAfterPartialContentWithPooling(WebClient client) throws Exception {
        serverRequestTimeoutMillis = 1000L;
        final CompletableFuture<AggregatedHttpResponse> f =
                client.get("/content_delay/2000?pooled").aggregate();

        // Because the service has written out the content partially, there's no way for the service
        // to reply with '503 Service Unavailable', so it will just close the stream.

        final Class<? extends Throwable> expectedCauseType =
                client.scheme().sessionProtocol().isMultiplex() ?
                ClosedStreamException.class : ClosedSessionException.class;

        assertThatThrownBy(f::get).isInstanceOf(ExecutionException.class)
                                  .hasCauseInstanceOf(expectedCauseType);
    }
Similar to {@link #testTimeoutAfterPartialContent(WebClient)}, but tests the case where the service
produces a pooled buffers.
core/src/test/java/com/linecorp/armeria/server/HttpServerTest.java