| /tonic/tonic/src/ |
| H A D | response.rs | 35 pub fn get_ref(&self) -> &T { in get_ref()
40 pub fn get_mut(&mut self) -> &mut T { in get_mut()
55 pub fn into_inner(self) -> T { in into_inner()
60 pub fn into_parts(self) -> (MetadataMap, T, Extensions) { in into_parts() argument
65 pub fn from_parts(metadata: MetadataMap, message: T, extensions: Extensions) -> Self { in from_parts()
82 pub(crate) fn into_http(self) -> http::Response<T> { in into_http()
|
| H A D | request.rs | 55 fn into_request(self) -> Request<T>; in into_request()
122 pub fn get_ref(&self) -> &T { in get_ref()
127 pub fn get_mut(&mut self) -> &mut T { in get_mut()
142 pub fn into_inner(self) -> T { in into_inner()
147 pub fn into_parts(self) -> (MetadataMap, Extensions, T) { in into_parts() argument
180 ) -> http::Request<T> { in into_http()
355 impl<T> IntoRequest<T> for T { implementation
362 fn into_request(self) -> Request<T> { in into_request()
367 impl<T> IntoStreamingRequest for T implementation
391 impl<T> sealed::Sealed for T {} implementation
[all …]
|
| /tonic/tonic-build/src/ |
| H A D | client.rs | 12 service: &T, in generate_internal()
168 service: &T, in generate_methods()
222 service: &T, in generate_unary()
253 service: &T, in generate_server_streaming()
284 service: &T, in generate_client_streaming()
315 service: &T, in generate_streaming()
|
| H A D | server.rs | 14 service: &T, in generate_internal()
198 service: &T, in generate_trait()
231 service: &T, in generate_trait_methods()
370 service: &T, in generate_methods()
436 method: &T, in generate_unary()
494 method: &T, in generate_server_streaming()
561 method: &T, in generate_client_streaming()
619 method: &T, in generate_streaming()
|
| H A D | lib.rs | 201 fn format_service_name<T: Service>(service: &T, emit_package: bool) -> String { in format_service_name()
211 fn format_method_path<T: Service>(service: &T, method: &T::Method, emit_package: bool) -> String { in format_method_path()
219 fn format_method_name<T: Service>(service: &T, method: &T::Method, emit_package: bool) -> String { in format_method_name()
|
| /tonic/tonic/src/server/ |
| H A D | service.rs | 21 impl<T, M1, M2> UnaryService<M1> for T implementation
51 impl<T, S, M1, M2> ServerStreamingService<M1> for T implementation
80 impl<T, M1, M2> ClientStreamingService<M1> for T implementation
110 impl<T, S, M1, M2> StreamingService<M1> for T implementation
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 155 fn data<T>(r: &Response<T>) -> &T { in data()
159 async fn stream<T>(r: Response<Streaming<T>>) -> Vec<T> { in stream()
|
| /tonic/tonic/src/codec/ |
| H A D | encode.rs | 36 encoder: T, in new()
134 encoder: &mut T, in encode_item()
235 encoder: T, in new_client()
259 encoder: T, in new_server()
|
| H A D | decode.rs | 329 pub async fn message(&mut self) -> Result<Option<T>, Status> { in message()
372 fn decode_chunk(&mut self) -> Result<Option<T>, Status> { in decode_chunk()
|
| /tonic/tonic/src/transport/server/ |
| H A D | conn.rs | 141 pub fn get_ref(&self) -> &T { in get_ref()
146 pub fn get_mut(&mut self) -> &mut T { in get_mut()
|
| /tonic/tonic/src/client/ |
| H A D | service.rs | 32 impl<T, ReqBody, ResBody> GrpcService<ReqBody> for T implementation
|
| H A D | grpc.rs | 59 pub fn with_origin(inner: T, origin: Uri) -> Self { in with_origin()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | add_origin.rs | 16 pub(crate) fn new(inner: T, origin: Uri) -> Self { in new()
|
| H A D | user_agent.rs | 14 pub(crate) fn new(inner: T, user_agent: Option<HeaderValue>) -> Self { in new()
|
| H A D | io.rs | 13 impl<T> Io for T where T: rt::Read + rt::Write + Send + 'static {} implementation
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 173 pub fn with_origin(inner: T, origin: Uri) -> Self { in with_origin()
178 inner: T, in with_interceptor()
180 ) -> ServerReflectionClient<InterceptedService<T, F>> in with_interceptor()
316 inner: T, in with_interceptor()
|
| H A D | grpc_reflection_v1alpha.rs | 173 pub fn with_origin(inner: T, origin: Uri) -> Self { in with_origin()
178 inner: T, in with_interceptor()
180 ) -> ServerReflectionClient<InterceptedService<T, F>> in with_interceptor()
316 inner: T, in with_interceptor()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 84 pub fn with_origin(inner: T, origin: Uri) -> Self { in with_origin()
89 inner: T, in with_interceptor()
91 ) -> HealthClient<InterceptedService<T, F>> in with_interceptor()
275 inner: T, in with_interceptor()
|
| /tonic/tonic/src/service/ |
| H A D | layered.rs | 61 impl<T> Sealed for T {} implementation
|
| /tonic/interop/src/ |
| H A D | client.rs | 231 fn validate_response<T>(result: Result<T, Status>, assertions: &mut Vec<TestAssertion>) in status_code_and_message()
|