Searched refs:Stream (Results 1 – 7 of 7) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | connector.rs | 24 type Stream: Read + Write + 'static; typedef
29 fn connect(&self, uri: &Uri) -> Result<Self::Stream, Self::Error>; in connect() argument
62 type Stream = TcpStream; typedef
65 fn connect(&self, uri: &Uri) -> Result<Self::Stream, Self::Error> { in connect() argument
87 type Stream = MixStream<TcpStream>; typedef
90 fn connect(&self, uri: &Uri) -> Result<Self::Stream, Self::Error> { in connect() argument
|
| D | pool.rs | 30 impl<C: Connector> ConnPool<C, C::Stream> {
38 pub(crate) fn connect_to(&self, uri: Uri) -> Result<Conn<C::Stream>, HttpClientError> { in connect_to() argument
|
| D | client.rs | 53 inner: ConnPool<C, C::Stream>,
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | connector.rs | 28 type Stream: AsyncRead + AsyncWrite + Unpin + Sync + Send + 'static; typedef
33 type Future: Future<Output = Result<Self::Stream, Self::Error>> + Unpin + Sync + Send + 'static;
83 type Stream = TcpStream; typedef
86 Pin<Box<dyn Future<Output = Result<Self::Stream, Self::Error>> + Sync + Send>>;
114 type Stream = MixStream<TcpStream>; typedef
117 Pin<Box<dyn Future<Output = Result<Self::Stream, Self::Error>> + Sync + Send>>;
|
| D | pool.rs | 31 impl<C: Connector> ConnPool<C, C::Stream> {
40 pub(crate) async fn connect_to(&self, uri: Uri) -> Result<Conn<C::Stream>, HttpClientError> { in connect_to() argument
|
| D | client.rs | 54 inner: ConnPool<C, C::Stream>,
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| D | mod.rs | 434 MultiPartState::Stream(ref mut stream) => { in poll_read_curr()
482 Stream(Pin<Box<dyn AsyncRead + Send + Sync>>), enumerator
491 Self::Stream(reader) in stream()
501 (Self::Stream(l0), Self::Stream(r0)) => core::ptr::eq(l0, r0), in eq()
512 Self::Stream(arg0) => f.debug_tuple("Stream").field(&(arg0 as *const _)).finish(), in fmt()
|