Searched refs:interceptor (Results 1 - 10 of 10) sorted by relevance
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
H A D | mod.rs | 32 mod interceptor; modules 53 pub use interceptor::{ConnDetail, ConnProtocol, Interceptor};
|
H A D | client.rs | 22 use crate::async_impl::interceptor::{IdleInterceptor, Interceptor, Interceptors}; 214 interceptor: Arc::clone(&self.interceptors), 449 /// # fn add_interceptor<T>(interceptor: T) 452 /// let builder = ClientBuilder::new().interceptor(interceptor); 455 pub fn interceptor<T>(mut self, interceptors: T) -> Self in interceptor() functions 977 use crate::async_impl::interceptor::IdleInterceptor;
|
H A D | request.rs | 27 use crate::async_impl::interceptor::Interceptors; 403 pub(crate) interceptor: Arc<Interceptors>,
|
H A D | http_body.rs | 27 use crate::async_impl::interceptor::Interceptors; 567 use crate::async_impl::interceptor::IdleInterceptor;
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
H A D | http1.rs | 27 use crate::async_impl::interceptor::Interceptors; 45 .interceptor 48 .interceptor 54 &message.interceptor, 77 message.interceptor.intercept_output(&buf[..size])?; 137 interceptor: &Arc<Interceptors>, 153 interceptor.intercept_input(&buf[..written])?; 217 let body = HttpBody::new(message.interceptor, length, Box::new(conn), pre)?; in decode_response()
|
H A D | http3.rs | 47 .interceptor 145 let body = HttpBody::new(message.interceptor, length, Box::new(data_io), &[0u8; 0])?; in frame_2_response()
|
H A D | http2.rs | 49 .interceptor 126 let body = HttpBody::new(message.interceptor, length, Box::new(text_io), &[0u8; 0])?; in frame_2_response()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
H A D | stream.rs | 19 use crate::async_impl::interceptor::ConnDetail;
|
H A D | mod.rs | 153 use crate::async_impl::interceptor::{ConnDetail, ConnProtocol}; 208 use crate::async_impl::interceptor::{ConnDetail, ConnProtocol};
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
H A D | mod.rs | 262 use crate::async_impl::interceptor::IdleInterceptor;
|
Completed in 8 milliseconds