Lines Matching refs:stream
90 let stream = tokio_stream::iter(requests); in client_streaming() localVariable
92 let result = client.streaming_input_call(Request::new(stream)).await; in client_streaming()
210 let stream = tokio_stream::empty(); in empty_stream() localVariable
211 let result = client.full_duplex_call(Request::new(stream)).await; in empty_stream()
273 let stream = tokio_stream::once(duplex_req); in status_code_and_message() localVariable
274 let result = match client.full_duplex_call(Request::new(stream)).await { in status_code_and_message()
276 let stream = response.into_inner(); in status_code_and_message() localVariable
277 let responses = stream.collect::<Vec<_>>().await; in status_code_and_message()
359 let stream = tokio_stream::once(make_ping_pong_request(0)); in custom_metadata() localVariable
360 let mut req_stream = Request::new(stream); in custom_metadata()
391 let mut stream = response.into_inner(); in custom_metadata() localVariable
393 let trailers = stream.trailers().await.unwrap().unwrap(); in custom_metadata()