Home
last modified time | relevance | path

Searched refs:UNCOMPRESSED_MIN_BODY_SIZE (Results 1 – 6 of 6) sorted by relevance

/tonic/tests/compression/src/
H A Dcompressing_request.rs14 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
73 data: [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(), in client_enabled_server_enabled()
78 assert!(bytes_sent < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()
91 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled_multi_encoding()
135 data: [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(), in client_enabled_server_enabled_multi_encoding()
140 assert!(bytes_sent < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled_multi_encoding()
153 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
170 data: [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(), in client_enabled_server_disabled()
204 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_mark_compressed_without_header_server_enabled()
229 data: [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(), in client_mark_compressed_without_header_server_enabled()
H A Dclient_stream.rs14 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
68 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in client_enabled_server_enabled()
75 assert!(bytes_sent < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()
87 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_disabled_server_enabled()
119 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in client_disabled_server_enabled()
126 assert!(bytes_sent > UNCOMPRESSED_MIN_BODY_SIZE); in client_disabled_server_enabled()
138 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
153 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in client_enabled_server_disabled()
184 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in compressing_response_from_client_stream()
225 assert!(bytes_sent < UNCOMPRESSED_MIN_BODY_SIZE); in compressing_response_from_client_stream()
H A Dlib.rs35 const UNCOMPRESSED_MIN_BODY_SIZE: usize = 1024; constant
50 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE]; in compress_output_unary()
58 assert_eq!(req.into_inner().data.len(), UNCOMPRESSED_MIN_BODY_SIZE); in compress_input_unary()
69 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in compress_output_server_stream()
96 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE]; in compress_output_client_stream()
115 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in compress_input_output_bidirectional_stream()
H A Dserver_stream.rs14 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
61 assert!(response_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()
68 assert!(response_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()
79 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_disabled_server_enabled()
119 assert!(response_bytes_counter.load(SeqCst) > UNCOMPRESSED_MIN_BODY_SIZE); in client_disabled_server_enabled()
131 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
172 assert!(response_bytes_counter.load(SeqCst) > UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_disabled()
H A Dcompressing_response.rs13 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
98 assert!(bytes_sent < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()
111 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
147 assert!(bytes_sent > UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_disabled()
152 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled_multi_encoding()
190 assert!(bytes_sent > UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_disabled_multi_encoding()
202 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_disabled()
261 assert!(bytes_sent > UNCOMPRESSED_MIN_BODY_SIZE); in client_disabled()
273 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in server_replying_with_unsupported_encoding()
361 assert!(bytes_sent > UNCOMPRESSED_MIN_BODY_SIZE); in disabling_compression_on_single_response()
[all …]
H A Dbidirectional_stream.rs14 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
79 let data = [0_u8; UNCOMPRESSED_MIN_BODY_SIZE].to_vec(); in client_enabled_server_enabled()
110 assert!(request_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()
111 assert!(response_bytes_counter.load(SeqCst) < UNCOMPRESSED_MIN_BODY_SIZE); in client_enabled_server_enabled()