Lines Matching refs:responses
130 let responses = response in server_streaming() localVariable
135 let actual_response_lengths = crate::response_lengths(&responses); in server_streaming()
139 responses.len() == 4, in server_streaming()
140 format!("responses.len()={:?}", responses.len()) in server_streaming()
170 let mut responses = Vec::new(); in ping_pong() localVariable
175 responses.push(result.unwrap()); in ping_pong()
176 if responses.len() == REQUEST_LENGTHS.len() { in ping_pong()
180 tx.send(make_ping_pong_request(responses.len())).unwrap(); in ping_pong()
195 let actual_response_lengths = crate::response_lengths(&responses); in ping_pong()
198 responses.len() == RESPONSE_LENGTHS.len(), in ping_pong()
199 format!("{:?}={:?}", responses.len(), RESPONSE_LENGTHS.len()) in ping_pong()
220 let responses = response.collect::<Vec<_>>().await; in empty_stream() localVariable
224 responses.is_empty(), in empty_stream()
225 format!("responses.len()={:?}", responses.len()) in empty_stream()
277 let responses = stream.collect::<Vec<_>>().await; in status_code_and_message() localVariable
278 Ok(responses) in status_code_and_message()