| /tonic/tonic/src/transport/channel/service/ |
| H A D | executor.rs | 13 pub(crate) fn new<E>(exec: E) -> Self in new() 15 E: Executor<BoxFuture<'static, ()>> + Send + Sync + 'static, in new()
|
| H A D | reconnect.rs | 202 impl<F, T, E> Future for ResponseFuture<F> 204 F: Future<Output = Result<T, E>>, 205 E: Into<crate::BoxError>,
|
| /tonic/tonic/src/ |
| H A D | codegen.rs | 19 pub type BoxFuture<T, E> = self::Pin<Box<dyn self::Future<Output = Result<T, E>> + Send + 'static>>;
|
| H A D | lib.rs | 135 pub type Result<T, E = Status> = std::result::Result<T, E>;
|
| H A D | status.rs | 432 pub(crate) fn map_error<E>(err: E) -> Status in map_error() 434 E: Into<Box<dyn Error + Send + Sync>>, in map_error()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 134 pub fn balance_channel_with_executor<K, E>( in balance_channel_with_executor() 136 executor: E, in balance_channel_with_executor() argument 140 E: Executor<Pin<Box<dyn Future<Output = ()> + Send>>> + Send + Sync + 'static, in balance_channel_with_executor() 190 pub(crate) fn balance<D, E>(discover: D, buffer_size: usize, executor: E) -> Self in balance() 195 E: Executor<BoxFuture<'static, ()>> + Send + Sync + 'static, in balance()
|
| H A D | endpoint.rs | 313 pub fn executor<E>(mut self, executor: E) -> Self in executor() 315 E: Executor<Pin<Box<dyn Future<Output = ()> + Send>>> + Send + Sync + 'static, in executor()
|
| /tonic/tonic-web/src/ |
| H A D | client.rs | 89 impl<F, B, E> Future for ResponseFuture<F> 91 F: Future<Output = Result<Response<B>, E>>, 93 type Output = Result<Response<GrpcWebCall<B>>, E>;
|
| H A D | service.rs | 155 impl<F, E> Future for ResponseFuture<F> 157 F: Future<Output = Result<Response<Body>, E>>, 159 type Output = Result<Response<Body>, E>; 253 type BoxFuture<T, E> = Pin<Box<dyn Future<Output = Result<T, E>> + Send>>;
|
| /tonic/examples/src/blocking/ |
| H A D | client.rs | 10 type Result<T, E = StdError> = ::std::result::Result<T, E>;
|
| /tonic/tonic/src/service/ |
| H A D | recover_error.rs | 85 impl<F, E, ResBody> Future for ResponseFuture<F> 87 F: Future<Output = Result<Response<ResBody>, E>>, 88 E: Into<crate::BoxError>,
|
| H A D | interceptor.rs | 193 impl<F, E, B> Future for ResponseFuture<F> 195 F: Future<Output = Result<http::Response<B>, E>>, 197 type Output = Result<http::Response<ResponseBody<B>>, E>;
|
| /tonic/tests/integration_tests/tests/ |
| H A D | complex_tower_middleware.rs | 78 impl<F, E, B> Future for MyFuture<F, B> 80 F: Future<Output = Result<http::Response<B>, E>>,
|
| /tonic/interop/data/ |
| H A D | server1.pem | 10 9ozEtInHvBOP7u2kE1kU+7V1ijG/vdHSS5/E/KrXMVqxzoES58XNtUqsRH09Gji8
|
| H A D | server1.key | 6 vBOP7u2kE1kU+7V1ijG/vdHSS5/E/KrXMVqxzoES58XNtUqsRH09Gji8ad/cD5GC
|
| /tonic/tonic/src/transport/service/ |
| H A D | grpc_timeout.rs | 73 impl<F, Res, E> Future for ResponseFuture<F> 75 F: Future<Output = Result<Res, E>>, 76 E: Into<crate::BoxError>,
|
| /tonic/interop/src/ |
| H A D | server.rs | 23 type BoxFuture<T, E> = Pin<Box<dyn Future<Output = StdResult<T, E>> + Send + 'static>>;
|
| /tonic/examples/data/gcp/ |
| H A D | roots.pem | 215 tJHUYmTbf6MG8YgYapAiPLz+E/CHFHv25B+O1ORRxhFnRghRy4YUVD+8M/5+bJz/ 1142 # SHA256 Fingerprint: 2A:57:54:71:E3:13:40:BC:21:58:1C:BD:2C:F1:3E:15:84:63:20:3E:CE:94:BC:F9:D3:CC… 1180 # MD5 Fingerprint: 44:ED:9A:0E:A4:09:3B:00:F2:AE:4C:A3:C6:61:B0:8B 1181 # SHA1 Fingerprint: D2:73:96:2A:2A:5E:39:9F:73:3F:E1:C7:1E:64:3F:03:38:34:FC:4D 1182 # SHA256 Fingerprint: C4:5D:7B:B0:8E:6D:67:E6:2E:42:35:11:0B:56:4E:5F:78:FD:92:EF:05:8C:84:0A:EA:4E… 1221 # SHA1 Fingerprint: 30:D4:24:6F:07:FF:DB:91:89:8A:0B:E9:49:66:11:EB:8C:5E:46:E5 1222 # SHA256 Fingerprint: 15:D5:B8:77:46:19:EA:7D:54:CE:1C:A6:D0:B0:C4:03:E0:37:A9:17:F1:31:E8:A0:4E:1E… 1242 # MD5 Fingerprint: 5D:B6:6A:C4:60:17:24:6A:1A:99:A8:4B:EE:5E:B4:26 1243 # SHA1 Fingerprint: 2A:1D:60:27:D9:4A:B1:0A:1C:4D:91:5C:CD:33:A0:CB:3E:2D:54:CB 1244 # SHA256 Fingerprint: 71:CC:A5:39:1F:9E:79:4B:04:80:25:30:B3:63:E1:21:DA:8A:30:43:BB:26:66:2F:EA:4D…
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 767 fn serve_connection<B, IO, S, E>( in serve_connection() 770 builder: ConnectionBuilder<E>, in serve_connection() argument 781 E: HttpServerConnExec<S::Future, B> + Send + Sync + 'static, in serve_connection() 1031 impl<F, E, ResBody> Future for SvcFuture<F> 1033 F: Future<Output = Result<Response<ResBody>, E>>, 1034 E: Into<crate::BoxError>,
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 485 fn compression_override_from_response<B, E>( in compression_override_from_response() argument 486 res: &Result<crate::Response<B>, E>, in compression_override_from_response()
|
| /tonic/tonic-types/proto/ |
| H A D | error_details.proto | 175 // field. E.g., "field_violations.field" would identify this field.
|