Home
last modified time | relevance | path

Searched refs:interceptor (Results 1 - 10 of 10) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dmod.rs32 mod interceptor; modules
53 pub use interceptor::{ConnDetail, ConnProtocol, Interceptor};
H A Dclient.rs22 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 Drequest.rs27 use crate::async_impl::interceptor::Interceptors;
403 pub(crate) interceptor: Arc<Interceptors>,
H A Dhttp_body.rs27 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 Dhttp1.rs27 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 Dhttp3.rs47 .interceptor
145 let body = HttpBody::new(message.interceptor, length, Box::new(data_io), &[0u8; 0])?; in frame_2_response()
H A Dhttp2.rs49 .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 Dstream.rs19 use crate::async_impl::interceptor::ConnDetail;
H A Dmod.rs153 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 Dmod.rs262 use crate::async_impl::interceptor::IdleInterceptor;

Completed in 8 milliseconds