Home
last modified time | relevance | path

Searched refs:Item (Results 1 – 25 of 42) sorted by relevance

12

/tonic/tonic/src/codec/
H A Dmod.rs111 type Encoder: Encoder<Item = Self::Encode, Error = Status> + Send + 'static;
113 type Decoder: Decoder<Item = Self::Decode, Error = Status> + Send + 'static;
124 type Item; typedef
132 fn encode(&mut self, item: Self::Item, dst: &mut EncodeBuf<'_>) -> Result<(), Self::Error>; in encode() argument
143 type Item; typedef
153 fn decode(&mut self, src: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error>; in decode() argument
H A Dprost.rs95 type Item = T; typedef
98 fn encode(&mut self, item: Self::Item, buf: &mut EncodeBuf<'_>) -> Result<(), Self::Error> { in encode() argument
128 type Item = U; typedef
131 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode() argument
318 type Item = Vec<u8>; typedef
321 fn encode(&mut self, item: Self::Item, buf: &mut EncodeBuf<'_>) -> Result<(), Self::Error> { in encode() argument
335 type Item = Vec<u8>; typedef
338 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode() argument
H A Dencode.rs73 U: Stream<Item = Result<T::Item, Status>>,
75 type Item = Result<Bytes, Status>; typedef
77 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() argument
140 item: T::Item, in encode_item() argument
306 U: Stream<Item = Result<T::Item, Status>>,
H A Ddecode.rs22 decoder: Box<dyn Decoder<Item = T, Error = Status> + Send + 'static>,
69 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_response() argument
85 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_empty() argument
101 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_request() argument
122 D: Decoder<Item = T, Error = Status> + Send + 'static, in new() argument
387 type Item = Result<T, Status>; typedef
389 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() argument
/tonic/examples/src/json-codec/
H A Dcommon.rs27 type Item = T; typedef
30 fn encode(&mut self, item: Self::Item, buf: &mut EncodeBuf<'_>) -> Result<(), Self::Error> { in encode() argument
39 type Item = U; typedef
42 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode() argument
47 let item: Self::Item = in decode()
/tonic/tests/integration_tests/tests/
H A Dstreams.rs6 Box<dyn tokio_stream::Stream<Item = std::result::Result<T, Status>> + Send + 'static>,
50 type Item = Result<OutputStream, Status>; typedef
55 ) -> std::task::Poll<Option<Self::Item>> { in poll_next() argument
H A Dmax_message_size.rs132 Pin<Box<dyn Stream<Item = Result<Output1, Status>> + Send + 'static>>; in response_stream_limit()
291 Pin<Box<dyn Stream<Item = Result<Output1, Status>> + Send + 'static>>; in max_message_run()
/tonic/tonic/src/transport/server/
H A Dio_stream.rs28 S: Stream<Item = Result<IO, IE>>,
38 S: Stream<Item = Result<IO, IE>>,
71 S: Stream<Item = Result<IO, IE>>,
75 type Item = Result<ServerIo<IO>, crate::BoxError>; typedef
78 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() argument
83 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() argument
146 incoming: &mut (impl Stream<Item = Result<IO, IE>> + Unpin), in select() argument
H A Dincoming.rs86 type Item = std::io::Result<TcpStream>; typedef
88 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() argument
/tonic/tonic/src/server/
H A Dservice.rs42 type ResponseStream: Stream<Item = Result<Self::Response, Status>>;
54 S: Stream<Item = Result<M2, crate::Status>>,
101 type ResponseStream: Stream<Item = Result<Self::Response, Status>>;
113 S: Stream<Item = Result<M2, crate::Status>>,
/tonic/tests/default_stubs/src/
H A Dlib.rs17 type ServerStreamStream = Pin<Box<dyn Stream<Item = Result<(), Status>> + Send + 'static>>;
19 Pin<Box<dyn Stream<Item = Result<(), Status>> + Send + 'static>>;
H A Dtest_defaults.rs9 fn echo_requests_iter() -> impl Stream<Item = ()> { in echo_requests_iter()
/tonic/tonic/src/transport/channel/service/
H A Ddiscover.rs32 type Item = Result<TowerChange<K, Connection>, crate::BoxError>; typedef
34 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { in poll_next() argument
/tonic/tonic/src/metadata/
H A Dmap.rs1236 type Item = KeyAndValueRef<'a>; typedef
1263 type Item = KeyAndMutValueRef<'a>; typedef
1290 type Item = MetadataValue<VE>; typedef
1306 type Item = KeyRef<'a>; typedef
1328 type Item = ValueRef<'a>; typedef
1349 type Item = ValueRefMut<'a>; typedef
1373 type Item = &'a MetadataValue<VE>; typedef
1412 type Item = &'a mut MetadataValue<VE>; typedef
1936 type Item = &'a MetadataValue<VE>; typedef
1992 type Item = &'a MetadataValue<VE>; typedef
[all …]
/tonic/tonic/src/transport/channel/
H A Dtls.rs46 pub fn ca_certificates(self, ca_certificates: impl IntoIterator<Item = Certificate>) -> Self { in ca_certificates() argument
65 trust_anchors: impl IntoIterator<Item = TrustAnchor<'static>>, in trust_anchors() argument
/tonic/tonic/src/
H A Dcodegen.rs21 self::Pin<Box<dyn tokio_stream::Stream<Item = Result<T, crate::Status>> + Send + 'static>>;
H A Drequest.rs92 type Stream: Stream<Item = Self::Message> + Send + 'static;
372 type Message = T::Item;
384 type Message = T::Item;
/tonic/tests/compression/src/
H A Dlib.rs63 Pin<Box<dyn Stream<Item = Result<SomeData, Status>> + Send + 'static>>;
104 Pin<Box<dyn Stream<Item = Result<SomeData, Status>> + Send + 'static>>;
/tonic/tonic-reflection/src/server/
H A Dv1alpha.rs120 type Item = Result<ServerReflectionResponse, Status>; typedef
125 ) -> std::task::Poll<Option<Self::Item>> { in poll_next() argument
H A Dv1.rs120 type Item = Result<ServerReflectionResponse, Status>; typedef
125 ) -> std::task::Poll<Option<Self::Item>> { in poll_next() argument
/tonic/tonic/benches/
H A Ddecode.rs103 type Item = Vec<u8>; typedef
106 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode() argument
/tonic/tonic/src/client/
H A Dgrpc.rs236 S: Stream<Item = M1> + Send + 'static, in client_streaming() argument
292 S: Stream<Item = M1> + Send + 'static, in streaming() argument
325 decoder: impl Decoder<Item = M2, Error = Status> + Send + 'static, in create_response() argument
/tonic/examples/src/streaming/
H A Dclient.rs11 fn echo_requests_iter() -> impl Stream<Item = EchoRequest> { in echo_requests_iter()
/tonic/tests/web/src/
H A Dlib.rs12 type BoxStream<T> = Pin<Box<dyn Stream<Item = Result<T, Status>> + Send + 'static>>;
/tonic/tonic-types/src/richer_error/
H A Dmod.rs121 details: impl IntoIterator<Item = ErrorDetail>, in with_error_details_vec_and_metadata() argument
145 details: impl IntoIterator<Item = ErrorDetail>, in with_error_details_vec() argument
546 details: impl IntoIterator<Item = ErrorDetail>, in with_error_details_vec_and_metadata() argument
596 details: impl IntoIterator<Item = ErrorDetail>, in with_error_details_vec() argument

12