13     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_enabled()
59     tokio::spawn({  in client_enabled_server_enabled()
111     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_disabled()
117     tokio::spawn({  in client_enabled_server_disabled()
150 #[tokio::test(flavor = "multi_thread")]
152     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_enabled_server_disabled_multi_encoding()
158     tokio::spawn({  in client_enabled_server_disabled_multi_encoding()
202     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in client_disabled()
232     tokio::spawn({  in client_disabled()
273     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in server_replying_with_unsupported_encoding()
284     tokio::spawn(async move {  in server_replying_with_unsupported_encoding()
317     let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10);  in disabling_compression_on_single_response()
326     tokio::spawn({  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()
384     tokio::spawn({  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()
453     tokio::spawn({  in disabling_compression_on_response_from_client_stream()