13     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_enabled()
78                 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server)))  in client_enabled_server_enabled()
111     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_disabled()
133                 .serve_with_incoming(tokio_stream::iter(vec![Ok::<_, std::io::Error>(server)]))  in client_enabled_server_disabled()
152     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_disabled_multi_encoding()
174                 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server)))  in client_enabled_server_disabled_multi_encoding()
202     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_disabled()
248                 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server)))  in client_disabled()
273     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in server_replying_with_unsupported_encoding()
292             .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server)))  in server_replying_with_unsupported_encoding()
317     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in disabling_compression_on_single_response()
341                 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server)))  in disabling_compression_on_single_response()
375     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in disabling_compression_on_response_but_keeping_compression_on_stream()
399                 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server)))  in disabling_compression_on_response_but_keeping_compression_on_stream()
444     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in disabling_compression_on_response_from_client_stream()
468                 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server)))  in disabling_compression_on_response_from_client_stream()