| /tonic/tonic/src/transport/channel/service/ |
| H A D | executor.rs | 27 impl<F> Executor<F> for SharedExec
29 F: Future<Output = ()> + Send + 'static,
31 fn execute(&self, fut: F) { in execute() argument
|
| H A D | reconnect.rs | 26 enum State<F, S> {
28 Connecting(F),
176 pub(crate) struct ResponseFuture<F> {
178 inner: Inner<F>,
183 enum Inner<F> {
184 Future(#[pin] F),
188 impl<F> ResponseFuture<F> {
189 pub(crate) fn new(inner: F) -> Self { in new()
202 impl<F, T, E> Future for ResponseFuture<F>
204 F: Future<Output = Result<T, E>>,
|
| /tonic/tonic-web/src/ |
| H A D | client.rs | 84 pub struct ResponseFuture<F> {
86 inner: F,
89 impl<F, B, E> Future for ResponseFuture<F>
91 F: Future<Output = Result<Response<B>, E>>,
102 impl<F> fmt::Debug for ResponseFuture<F> {
|
| H A D | service.rs | 123 pub struct ResponseFuture<F> {
125 case: Case<F>,
129 enum Case<F> {
132 future: F,
137 future: F,
144 impl<F> Case<F> {
155 impl<F, E> Future for ResponseFuture<F>
157 F: Future<Output = Result<Response<Body>, E>>,
183 impl<F> fmt::Debug for ResponseFuture<F> {
|
| /tonic/tonic/src/service/ |
| H A D | interceptor.rs | 46 impl<F> Interceptor for F implementation
48 F: FnMut(crate::Request<()>) -> Result<crate::Request<()>, Status>,
167 pub struct ResponseFuture<F> {
169 kind: Kind<F>,
172 impl<F> ResponseFuture<F> {
173 fn future(future: F) -> Self { in future()
188 enum Kind<F> {
189 Future(#[pin] F),
193 impl<F, E, B> Future for ResponseFuture<F>
195 F: Future<Output = Result<http::Response<B>, E>>,
|
| H A D | recover_error.rs | 74 pub struct ResponseFuture<F> {
76 inner: F,
79 impl<F> fmt::Debug for ResponseFuture<F> {
85 impl<F, E, ResBody> Future for ResponseFuture<F>
87 F: Future<Output = Result<Response<ResBody>, E>>,
|
| /tonic/tests/integration_tests/tests/ |
| H A D | complex_tower_middleware.rs | 73 struct MyFuture<F, B> {
74 inner: F,
78 impl<F, E, B> Future for MyFuture<F, B>
80 F: Future<Output = Result<http::Response<B>, E>>,
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 386 pub fn trace_fn<F>(self, f: F) -> Self in trace_fn()
565 signal: F, in serve_with_shutdown() argument
609 signal: F, in serve_with_incoming_shutdown() argument
899 signal: F, in serve_with_shutdown() argument
954 signal: F, in serve_with_incoming_shutdown() argument
1025 struct SvcFuture<F> {
1027 inner: F,
1031 impl<F, E, ResBody> Future for SvcFuture<F>
1112 struct Fuse<F> {
1117 impl<F> Future for Fuse<F>
[all …]
|
| /tonic/tonic/src/ |
| H A D | response.rs | 93 pub fn map<F, U>(self, f: F) -> Response<U> in map() argument
95 F: FnOnce(T) -> U, in map()
|
| H A D | request.rs | 196 pub fn map<F, U>(self, f: F) -> Request<U> in map() argument
198 F: FnOnce(T) -> U, in map()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 88 pub fn with_interceptor<F>( in with_interceptor()
90 interceptor: F, in with_interceptor() argument
91 ) -> HealthClient<InterceptedService<T, F>> in with_interceptor()
93 F: tonic::service::Interceptor, in with_interceptor()
274 pub fn with_interceptor<F>( in with_interceptor()
276 interceptor: F, in with_interceptor() argument
277 ) -> InterceptedService<Self, F> in with_interceptor()
279 F: tonic::service::Interceptor, in with_interceptor()
|
| /tonic/tonic/src/transport/service/ |
| H A D | grpc_timeout.rs | 66 pub(crate) struct ResponseFuture<F> {
68 inner: F,
73 impl<F, Res, E> Future for ResponseFuture<F>
75 F: Future<Output = Result<Res, E>>,
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 177 pub fn with_interceptor<F>( in with_interceptor()
179 interceptor: F, in with_interceptor() argument
180 ) -> ServerReflectionClient<InterceptedService<T, F>> in with_interceptor()
182 F: tonic::service::Interceptor, in with_interceptor()
315 pub fn with_interceptor<F>( in with_interceptor()
317 interceptor: F, in with_interceptor() argument
318 ) -> InterceptedService<Self, F> in with_interceptor()
320 F: tonic::service::Interceptor, in with_interceptor()
|
| H A D | grpc_reflection_v1alpha.rs | 177 pub fn with_interceptor<F>( in with_interceptor()
179 interceptor: F, in with_interceptor() argument
180 ) -> ServerReflectionClient<InterceptedService<T, F>> in with_interceptor()
182 F: tonic::service::Interceptor, in with_interceptor()
315 pub fn with_interceptor<F>( in with_interceptor()
317 interceptor: F, in with_interceptor() argument
318 ) -> InterceptedService<Self, F> in with_interceptor()
320 F: tonic::service::Interceptor, in with_interceptor()
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 85 … pub fn with_interceptor<F>(inner: T, interceptor: F) -> #service_ident<InterceptedService<T, F>> in generate_internal()
87 F: tonic::service::Interceptor, in generate_internal()
|
| H A D | server.rs | 137 pub fn with_interceptor<F>(inner: T, interceptor: F) -> InterceptedService<Self, F> in generate_internal()
139 F: tonic::service::Interceptor, in generate_internal()
|
| /tonic/examples/data/gcp/ |
| H A D | roots.pem | 1140 # MD5 Fingerprint: 82:1A:EF:D4:D2:4A:F2:9F:E2:3D:97:06:14:70:72:85
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
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/examples/proto/googleapis/google/api/ |
| H A D | http.proto | 36 // cases of single segment matches in reserved expansion, where "%2F" will be
257 // The server side does the reverse decoding, except "%2F" and "%2f" are left
|
| /tonic/tonic/src/metadata/ |
| H A D | map.rs | 1505 pub fn or_insert_with<F: FnOnce() -> MetadataValue<VE>>( in or_insert_with()
1507 default: F, in or_insert_with() argument
|