Home
last modified time | relevance | path

Searched refs:item (Results 1 – 11 of 11) sorted by relevance

/tonic/tests/compression/src/
H A Dlib.rs81 while let Some(item) = stream.next().await { in compress_input_client_stream()
82 item.unwrap(); in compress_input_client_stream()
92 while let Some(item) = stream.next().await { in compress_output_client_stream()
93 item.unwrap(); in compress_output_client_stream()
111 while let Some(item) = stream.next().await { in compress_input_output_bidirectional_stream()
112 item.unwrap(); in compress_input_output_bidirectional_stream()
/tonic/examples/src/json-codec/
H A Dcommon.rs30 fn encode(&mut self, item: Self::Item, buf: &mut EncodeBuf<'_>) -> Result<(), Self::Error> { in encode()
31 serde_json::to_writer(buf.writer(), &item).map_err(|e| Status::internal(e.to_string())) in encode()
47 let item: Self::Item = in decode() localVariable
49 Ok(Some(item)) in decode()
/tonic/tonic-health/src/
H A Dserver.rs280 let item = resp in test_service_watch() localVariable
285 assert_serving_status(item.status, ServingStatus::Serving); in test_service_watch()
306 let item = resp in test_service_watch() localVariable
311 assert_serving_status(item.status, ServingStatus::Unknown); in test_service_watch()
318 let item = resp in test_service_watch() localVariable
323 assert_serving_status(item.status, ServingStatus::NotServing); in test_service_watch()
329 let item = resp in test_service_watch() localVariable
334 assert_serving_status(item.status, ServingStatus::Serving); in test_service_watch()
338 let item = resp.next().await; in test_service_watch() localVariable
339 assert!(item.is_none()); in test_service_watch()
/tonic/tonic/src/codec/
H A Dprost.rs98 fn encode(&mut self, item: Self::Item, buf: &mut EncodeBuf<'_>) -> Result<(), Self::Error> { in encode()
99 item.encode(buf) in encode()
132 let item = Message::decode(buf) in decode() localVariable
136 Ok(item) in decode()
321 fn encode(&mut self, item: Self::Item, buf: &mut EncodeBuf<'_>) -> Result<(), Self::Error> { in encode()
322 buf.put(&item[..]); in encode()
H A Dencode.rs104 Poll::Ready(Some(Ok(item))) => { in poll_next()
112 item, in poll_next()
140 item: T::Item, in encode_item()
156 .encode(item, &mut EncodeBuf::new(uncompression_buf)) in encode_item()
173 .encode(item, &mut EncodeBuf::new(buf)) in encode_item()
H A Dmod.rs132 fn encode(&mut self, item: Self::Item, dst: &mut EncodeBuf<'_>) -> Result<(), Self::Error>; in encode()
H A Ddecode.rs398 if let Some(item) = self.decode_chunk()? { in poll_next()
399 return Poll::Ready(Some(Ok(item))); in poll_next()
/tonic/examples/src/streaming/
H A Dclient.rs28 while let Some(item) = stream.next().await { in streaming_echo()
29 println!("\treceived: {}", item.unwrap().message); in streaming_echo()
H A Dserver.rs63 while let Some(item) = stream.next().await { in server_streaming_echo()
64 match tx.send(Result::<_, Status>::Ok(item)).await { in server_streaming_echo()
/tonic/tonic/src/metadata/
H A Dmap.rs1239 self.inner.next().map(|item| { in next()
1240 let (name, value) = item; in next()
1266 self.inner.next().map(|item| { in next()
1267 let (name, value) = item; in next()
1331 self.inner.next().map(|item| { in next()
1332 let (name, value) = item; in next()
1352 self.inner.next().map(|item| { in next()
1353 let (name, value) = item; in next()
/tonic/
H A DCONTRIBUTING.md168 /// let process = rx.for_each(|item| {
169 /// // do something with `item`
170 /// # drop(item);