Home
last modified time | relevance | path

Searched refs:Send (Results 1 – 25 of 55) sorted by relevance

123

/tonic/tonic/src/transport/server/
H A Dmod.rs406 + Send in add_service()
410 S::Future: Send + 'static, in add_service()
430 + Send in add_optional_service()
434 S::Future: Send + 'static, in add_optional_service()
775 B::Data: Send, in serve_connection() argument
776 B::Error: Into<Box<dyn std::error::Error + Send + Sync>> + Send + Sync, in serve_connection()
779 S::Future: Send + 'static, in serve_connection()
780 S::Error: Into<Box<dyn std::error::Error + Send + Sync>> + Send, in serve_connection() argument
840 + Send in add_service()
860 + Send in add_optional_service()
[all …]
/tonic/tonic/src/transport/channel/
H A Dmod.rs38 type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>;
124 K: Hash + Eq + Send + Clone + 'static, in balance_channel()
139 K: Hash + Eq + Send + Clone + 'static, in balance_channel_with_executor()
140 E: Executor<Pin<Box<dyn Future<Output = ()> + Send>>> + Send + Sync + 'static, in balance_channel_with_executor()
152 C: Service<Uri> + Send + 'static, in new()
153 C::Error: Into<crate::BoxError> + Send, in new() argument
154 C::Future: Send, in new() argument
173 C: Service<Uri> + Send + 'static, in connect()
174 C::Error: Into<crate::BoxError> + Send, in connect() argument
175 C::Future: Unpin + Send, in connect() argument
[all …]
H A Dendpoint.rs315 E: Executor<Pin<Box<dyn Future<Output = ()> + Send>>> + Send + Sync + 'static, in executor()
371 C: Service<Uri> + Send + 'static, in connect_with_connector()
372 C::Response: rt::Read + rt::Write + Send + Unpin, in connect_with_connector()
373 C::Future: Send, in connect_with_connector() argument
374 crate::BoxError: From<C::Error> + Send, in connect_with_connector() argument
396 C: Service<Uri> + Send + 'static, in connect_with_connector_lazy()
397 C::Response: rt::Read + rt::Write + Send + Unpin, in connect_with_connector_lazy()
398 C::Future: Send, in connect_with_connector_lazy() argument
399 crate::BoxError: From<C::Error> + Send, in connect_with_connector_lazy() argument
/tonic/tonic/src/transport/channel/service/
H A Dconnection.rs30 C: Service<Uri> + Send + 'static, in new()
31 C::Error: Into<crate::BoxError> + Send, in new() argument
32 C::Future: Send, in new() argument
85 C: Service<Uri> + Send + 'static, in connect()
86 C::Error: Into<crate::BoxError> + Send, in connect() argument
87 C::Future: Unpin + Send, in connect() argument
95 C: Service<Uri> + Send + 'static, in lazy()
97 C::Future: Send, in lazy() argument
176 C: Service<Uri> + Send + 'static,
177 C::Error: Into<crate::BoxError> + Send,
[all …]
H A Dexecutor.rs9 inner: Arc<dyn Executor<BoxFuture<'static, ()>> + Send + Sync + 'static>,
15 E: Executor<BoxFuture<'static, ()>> + Send + Sync + 'static, in new()
29 F: Future<Output = ()> + Send + 'static,
H A Dconnector.rs36 C::Response: rt::Read + rt::Write + Unpin + Send + 'static,
37 C::Future: Send + 'static,
38 crate::BoxError: From<C::Error> + Send + 'static,
H A Dio.rs9 rt::Read + rt::Write + Send + 'static
13 impl<T> Io for T where T: rt::Read + rt::Write + Send + 'static {}
/tonic/tonic/src/client/
H A Dgrpc.rs215 T::ResponseBody: HttpBody + Send + 'static, in unary()
218 M1: Send + Sync + 'static, in unary()
219 M2: Send + Sync + 'static, in unary()
236 S: Stream<Item = M1> + Send + 'static, in client_streaming()
238 M1: Send + Sync + 'static, in client_streaming()
239 M2: Send + Sync + 'static, in client_streaming()
274 M1: Send + Sync + 'static, in server_streaming()
275 M2: Send + Sync + 'static, in server_streaming()
292 S: Stream<Item = M1> + Send + 'static, in streaming()
294 M1: Send + Sync + 'static, in streaming()
[all …]
/tonic/tonic/src/server/
H A Dgrpc.rs226 B: HttpBody + Send + 'static, in unary()
227 B::Error: Into<crate::BoxError> + Send, in unary() argument
269 S::ResponseStream: Send + 'static, in server_streaming()
270 B: HttpBody + Send + 'static, in server_streaming()
271 B::Error: Into<crate::BoxError> + Send, in server_streaming() argument
310 B: HttpBody + Send + 'static, in client_streaming()
343 S::ResponseStream: Send + 'static, in streaming()
344 B: HttpBody + Send + 'static, in streaming()
345 B::Error: Into<crate::BoxError> + Send, in streaming() argument
369 B: HttpBody + Send + 'static, in map_request_unary()
[all …]
/tonic/tonic/src/
H A Dcodegen.rs11 pub type StdError = Box<dyn std::error::Error + Send + Sync + 'static>;
19 pub type BoxFuture<T, E> = self::Pin<Box<dyn self::Future<Output = Result<T, E>> + Send + 'static>>;
21 self::Pin<Box<dyn tokio_stream::Stream<Item = Result<T, crate::Status>> + Send + 'static>>;
/tonic/tonic/src/service/
H A Drouter.rs31 + Send in add_service()
35 S::Future: Send + 'static, in add_service()
63 + Send in new()
67 S::Future: Send + 'static, in new()
83 + Send in add_service()
87 S::Future: Send + 'static, in add_service()
145 B: http_body::Body<Data = bytes::Bytes> + Send + 'static,
/tonic/tonic/src/codec/
H A Dmod.rs106 type Encode: Send + 'static;
108 type Decode: Send + 'static;
111 type Encoder: Encoder<Item = Self::Encode, Error = Status> + Send + 'static;
113 type Decoder: Decoder<Item = Self::Decode, Error = Status> + Send + 'static;
H A Ddecode.rs22 decoder: Box<dyn Decoder<Item = T, Error = Status> + Send + 'static>,
67 B: HttpBody + Send + 'static, in new_response()
69 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_response()
83 B: HttpBody + Send + 'static, in new_empty()
85 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_empty()
99 B: HttpBody + Send + 'static, in new_request()
101 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_request()
120 B: HttpBody + Send + 'static, in new()
122 D: Decoder<Item = T, Error = Status> + Send + 'static, in new()
421 static_assertions::assert_impl_all!(Streaming<()>: Send);
/tonic/examples/src/tower/
H A Dserver.rs81 type BoxFuture<'a, T> = Pin<Box<dyn std::future::Future<Output = T> + Send + 'a>>;
85 S: Service<http::Request<ReqBody>, Response = http::Response<ResBody>> + Clone + Send + 'static,
86 S::Future: Send + 'static,
87 ReqBody: Send + 'static,
/tonic/examples/src/codec_buffers/
H A Dcommon.rs22 T: Message + Send + 'static,
23 U: Message + Default + Send + 'static,
/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>>;
/tonic/examples/src/h2c/
H A Dserver.rs80 type BoxError = Box<dyn std::error::Error + Send + Sync>;
84 S: Service<Request<Body>, Response = Response<Body>> + Clone + Send + 'static,
85 S::Future: Send,
91 Pin<Box<dyn std::future::Future<Output = Result<Self::Response, Self::Error>> + Send>>;
/tonic/tests/integration_tests/tests/
H A Dstreams.rs6 Box<dyn tokio_stream::Stream<Item = std::result::Result<T, Status>> + Send + 'static>,
47 unsafe impl Send for Unsync {}
H A Dorigin.rs87 T::Future: Send + 'static,
88 T::Error: Into<Box<dyn std::error::Error + Send + Sync>>,
91 type Error = Box<dyn std::error::Error + Send + Sync>;
/tonic/tonic-health/src/generated/
H A Dgrpc_health_v1.rs77 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
78 <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
103 >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync, in with_interceptor()
217 pub trait Health: std::marker::Send + std::marker::Sync + 'static {
231 + std::marker::Send
315 B: Body + std::marker::Send + 'static,
316 B::Error: Into<StdError> + std::marker::Send + 'static,
/tonic/examples/src/cancellation/
H A Dserver.rs54 FRequest: Future<Output = Result<Response<HelloReply>, Status>> + Send + 'static, in with_cancellation_handler()
55 FCancellation: Future<Output = Result<Response<HelloReply>, Status>> + Send + 'static, in with_cancellation_handler()
/tonic/examples/src/json-codec/
H A Dcommon.rs65 T: serde::Serialize + Send + 'static,
66 U: serde::de::DeserializeOwned + Send + 'static,
/tonic/tonic/benches-disabled/benchmarks/compiled_protos/
H A Dhelloworld.rs35 T::ResponseBody: Body + Send + 'static,
37 <T::ResponseBody as Body>::Error: Into<StdError> + Send,
38 <T::ResponseBody as Body>::Data: Into<bytes::Bytes> + Send,
78 pub trait Greeter: Send + Sync + 'static {
/tonic/tonic-reflection/src/generated/
H A Dgrpc_reflection_v1.rs166 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
167 <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
192 >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync, in with_interceptor()
274 pub trait ServerReflection: std::marker::Send + std::marker::Sync + 'static {
282 + std::marker::Send
356 B: Body + std::marker::Send + 'static,
357 B::Error: Into<StdError> + std::marker::Send + 'static,
H A Dgrpc_reflection_v1alpha.rs166 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
167 <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
192 >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync, in with_interceptor()
274 pub trait ServerReflection: std::marker::Send + std::marker::Sync + 'static {
282 + std::marker::Send
356 B: Body + std::marker::Send + 'static,
357 B::Error: Into<StdError> + std::marker::Send + 'static,

123