Home
last modified time | relevance | path

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

/tonic/tonic/src/server/
H A Dgrpc.rs219 pub async fn unary<S, B>( in unary()
222 req: http::Request<B>, in unary() argument
265 req: http::Request<B>, in server_streaming() argument
306 req: http::Request<B>, in client_streaming() argument
336 pub async fn streaming<S, B>( in streaming()
339 req: http::Request<B>, in streaming() argument
364 async fn map_request_unary<B>( in map_request_unary()
366 request: http::Request<B>, in map_request_unary() argument
397 fn map_request_streaming<B>( in map_request_streaming()
399 request: http::Request<B>, in map_request_streaming() argument
[all …]
/tonic/tests/integration_tests/tests/
H A Dcomplex_tower_middleware.rs73 struct MyFuture<F, B> {
75 body: B,
78 impl<F, E, B> Future for MyFuture<F, B>
80 F: Future<Output = Result<http::Response<B>, E>>,
82 type Output = Result<http::Response<MyBody<B>>, BoxError>;
89 struct MyBody<B> {
90 inner: B,
93 impl<B> Body for MyBody<B>
95 B: Body,
97 type Data = B::Data;
/tonic/tonic/src/service/
H A Drecover_error.rs112 pub struct ResponseBody<B> {
114 inner: Option<B>,
117 impl<B> fmt::Debug for ResponseBody<B> {
123 impl<B> ResponseBody<B> {
124 fn full(inner: B) -> Self { in full()
133 impl<B> http_body::Body for ResponseBody<B>
135 B: http_body::Body,
137 type Data = B::Data;
138 type Error = B::Error;
H A Dinterceptor.rs193 impl<F, E, B> Future for ResponseFuture<F>
214 pub struct ResponseBody<B> {
216 kind: ResponseBodyKind<B>,
221 enum ResponseBodyKind<B> {
223 Wrap(#[pin] B),
226 impl<B> ResponseBody<B> {
227 fn new(kind: ResponseBodyKind<B>) -> Self { in new()
235 fn wrap(body: B) -> Self { in wrap()
240 impl<B: http_body::Body> http_body::Body for ResponseBody<B> {
241 type Data = B::Data;
[all …]
H A Drouter.rs143 impl<B> Service<Request<B>> for Routes
145 B: http_body::Body<Data = bytes::Bytes> + Send + 'static,
146 B::Error: Into<crate::BoxError>,
157 fn call(&mut self, req: Request<B>) -> Self::Future { in call()
/tonic/tests/compression/src/
H A Dutil.rs39 pub struct CountBytesBody<B> {
41 pub inner: B,
45 impl<B> HttpBody for CountBytesBody<B>
47 B: HttpBody<Data = Bytes>,
49 type Data = B::Data;
50 type Error = B::Error;
160 pub fn call<B: HttpBody>(self, req: http::Request<B>) -> http::Request<B> { in call() argument
H A Dcompressing_request.rs31 pub fn call<B: Body>(self, req: http::Request<B>) -> http::Request<B> { in client_enabled_server_enabled() argument
100 fn assert_right_encoding<B>(req: http::Request<B>) -> http::Request<B> { in client_enabled_server_enabled_multi_encoding() argument
H A Dcompressing_response.rs21 impl<S, B> Service<http::Request<B>> for AssertCorrectAcceptEncoding<S> in client_enabled_server_enabled()
23 S: Service<http::Request<B>>, in client_enabled_server_enabled()
36 fn call(&mut self, req: http::Request<B>) -> Self::Future { in client_enabled_server_enabled()
207 impl<S, B> Service<http::Request<B>> for AssertCorrectAcceptEncoding<S> in client_disabled()
209 S: Service<http::Request<B>>, in client_disabled()
222 fn call(&mut self, req: http::Request<B>) -> Self::Future { in client_disabled()
277 fn add_weird_content_encoding<B>(mut response: http::Response<B>) -> http::Response<B> { in server_replying_with_unsupported_encoding() argument
H A Dclient_stream.rs31 pub fn call<B: Body>(self, req: http::Request<B>) -> http::Request<B> { in client_enabled_server_enabled() argument
93 fn assert_right_encoding<B>(req: http::Request<B>) -> http::Request<B> { in client_disabled_server_enabled() argument
H A Dbidirectional_stream.rs34 pub fn call<B: Body>(self, req: http::Request<B>) -> http::Request<B> { in client_enabled_server_enabled() argument
H A Dlib.rs38 fn prepare_response<B>(&self, mut res: Response<B>) -> Response<B> { in prepare_response() argument
/tonic/tonic/src/codec/
H A Ddecode.rs59 pub fn new_response<B, D>( in new_response() argument
61 body: B, in new_response() argument
67 B: HttpBody + Send + 'static, in new_response()
81 pub fn new_empty<B, D>(decoder: D, body: B) -> Self in new_empty() argument
83 B: HttpBody + Send + 'static, in new_empty()
92 pub fn new_request<B, D>( in new_request() argument
94 body: B, in new_request() argument
99 B: HttpBody + Send + 'static, in new_request()
112 fn new<B, D>( in new() argument
114 body: B, in new() argument
[all …]
/tonic/tonic-web/src/
H A Dcall.rs62 pub struct GrpcWebCall<B> {
64 inner: B,
73 impl<B: Default> Default for GrpcWebCall<B> {
87 impl<B> GrpcWebCall<B> {
161 impl<B> GrpcWebCall<B>
163 B: Body,
164 B::Data: Buf,
250 impl<B> Body for GrpcWebCall<B>
252 B: Body,
339 impl<B> Stream for GrpcWebCall<B>
[all …]
H A Dservice.rs46 impl<S, B> Service<Request<B>> for GrpcWebService<S>
49 B: http_body::Body<Data = bytes::Bytes> + Send + 'static,
50 B::Error: Into<crate::BoxError> + fmt::Display,
60 fn call(&mut self, req: Request<B>) -> Self::Future { in call()
206 fn coerce_request<B>(mut req: Request<B>, encoding: Encoding) -> Request<Body> in coerce_request() argument
208 B: http_body::Body<Data = bytes::Bytes> + Send + 'static, in coerce_request()
209 B::Error: Into<crate::BoxError> + fmt::Display, in coerce_request()
227 fn coerce_response<B>(res: Response<B>, encoding: Encoding) -> Response<Body> in coerce_response() argument
229 B: http_body::Body<Data = bytes::Bytes> + Send + 'static, in coerce_response()
230 B::Error: Into<crate::BoxError> + fmt::Display, in coerce_response()
H A Dclient.rs89 impl<F, B, E> Future for ResponseFuture<F>
91 F: Future<Output = Result<Response<B>, E>>,
93 type Output = Result<Response<GrpcWebCall<B>>, E>;
/tonic/tonic/src/
H A Dbody.rs33 pub fn new<B>(body: B) -> Self in new()
35 B: http_body::Body<Data = bytes::Bytes> + Send + 'static, in new()
36 B::Error: Into<crate::BoxError>, in new()
H A Dstatus.rs578 pub fn into_http<B: Default>(self) -> http::Response<B> { in into_http() argument
579 let mut response = http::Response::new(B::default()); in into_http()
/tonic/examples/data/tls/
H A Dclient1.pem6 ysHJ9nH9mcl0Jkc7cxNgTqwIuFiyx/TKAAQQbG+aR3hzGZ8J+B/G5Py74PtjnNBK
/tonic/tonic-health/src/generated/
H A Dgrpc_health_v1.rs312 impl<T, B> tonic::codegen::Service<http::Request<B>> for HealthServer<T>
315 B: Body + std::marker::Send + 'static,
316 B::Error: Into<StdError> + std::marker::Send + 'static,
327 fn call(&mut self, req: http::Request<B>) -> Self::Future { in call()
/tonic/tonic-reflection/src/generated/
H A Dgrpc_reflection_v1.rs353 impl<T, B> tonic::codegen::Service<http::Request<B>> for ServerReflectionServer<T>
356 B: Body + std::marker::Send + 'static,
357 B::Error: Into<StdError> + std::marker::Send + 'static,
368 fn call(&mut self, req: http::Request<B>) -> Self::Future { in call()
H A Dgrpc_reflection_v1alpha.rs353 impl<T, B> tonic::codegen::Service<http::Request<B>> for ServerReflectionServer<T>
356 B: Body + std::marker::Send + 'static,
357 B::Error: Into<StdError> + std::marker::Send + 'static,
368 fn call(&mut self, req: http::Request<B>) -> Self::Future { in call()
/tonic/examples/data/gcp/
H A Droots.pem213 AoICAQCAEmUXNg7D2wiz0KxXDXbtzSfTTK1Qg2HiqiBNCS1kCdzOiZ/MPans9s/B
604 AGAT/3B+XxFNSRuzFVJ7yVTav52Vr2ua2J7p8eRDjeIRRDq/r72DQnNSi6q7pynP
934 AQH/MB0GA1UdDgQWBBSubAWjkxPioufi1xzWx/B/yGdToDAfBgNVHSMEGDAWgBSu
935 bAWjkxPioufi1xzWx/B/yGdToDANBgkqhkiG9w0BAQwFAAOCAgEAgyXt6NH9lVLN
1005 dloedl40wOiWVpmKs/B/pM293DIxfJHP4F8R+GuqSVzRmZTRouNjWwl2tVZi4Ut0
1141 # SHA1 Fingerprint: E1:C9:50:E6:EF:22:F8:4C:56:45:72:8B:92:20:60:D7:D5:A7:A3:E8
1180 # MD5 Fingerprint: 44:ED:9A:0E:A4:09:3B:00:F2:AE:4C:A3:C6:61:B0:8B
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…
1202 8KZ3/p7uC4Gt4cCpx/k1HUCCq+YEtN/L9x0Pg/B+E02NjO7jMyLDOfxA325BS0JT
1220 # MD5 Fingerprint: 1A:79:5B:6B:04:52:9C:5D:C7:74:33:1B:25:9A:F9:25
[all …]
/tonic/tonic-build/src/
H A Dserver.rs149 impl<T, B> tonic::codegen::Service<http::Request<B>> for #server_service<T> in generate_internal()
152 B: Body + std::marker::Send + 'static, in generate_internal()
153 B::Error: Into<StdError> + std::marker::Send + 'static, in generate_internal()
163 fn call(&mut self, req: http::Request<B>) -> Self::Future { in generate_internal()
/tonic/tonic/src/transport/server/
H A Dmod.rs767 fn serve_connection<B, IO, S, E>( in serve_connection() argument
774 B: http_body::Body + Send + 'static, in serve_connection()
775 B::Data: Send, in serve_connection()
776 B::Error: Into<Box<dyn std::error::Error + Send + Sync>> + Send + Sync, in serve_connection()
778 S: HyperService<Request<Incoming>, Response = Response<B>> + Clone + Send + 'static, in serve_connection()
781 E: HttpServerConnExec<S::Future, B> + Send + Sync + 'static, in serve_connection()
/tonic/examples/proto/googleapis/google/api/
H A Dhttp.proto120 // as `...?param=A&param=B`. In the case of a message type, each field of the
122 // `...?foo.a=A&foo.b=B&foo.c=C`.