Searched defs:Stream (Results 1 – 9 of 9) 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()
62 type Stream = TcpStream; typedef
65 fn connect(&self, uri: &Uri) -> Result<Self::Stream, Self::Error> { in connect()
87 type Stream = MixStream<TcpStream>; typedef
90 fn connect(&self, uri: &Uri) -> Result<Self::Stream, Self::Error> { in connect()
|
| D | pool.rs | 39 pub(crate) fn connect_to(&self, uri: Uri) -> Result<Conn<C::Stream>, HttpClientError> { in connect_to()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | pool.rs | 71 ) -> Result<TimeInfoConn<C::Stream>, HttpClientError> { in connect_to()
161 C: Connector<Stream = S>, in conn()
199 C: Connector<Stream = S>, in conn_h1()
223 C: Connector<Stream = S>, in conn_h2()
260 C: Connector<Stream = S>, in conn_h3()
290 C: Connector<Stream = S>, in conn_negotiate()
336 ) -> Option<TimeInfoConn<S>> in conn_alt_svc()
|
| D | request.rs | 268 Stream(Box<dyn ReusableReader + Send + Sync + Unpin>), enumerator
|
| D | client.rs | 230 async fn connect_to(&self, uri: &Uri) -> Result<TimeInfoConn<C::Stream>, HttpClientError> { in connect_to()
244 conn: Conn<C::Stream>, in send_request_on_conn()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | streams.rs | 121 pub(crate) struct Stream { struct
124 pub(crate) state: H2StreamState, argument
135 pub(crate) struct Streams { argument
745 impl Stream { implementation
813 fn stream_new(state: H2StreamState) -> Stream { in stream_new()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 39 type Stream: AsyncRead + AsyncWrite + ConnInfo + Unpin + Sync + Send + 'static; typedef
170 type Stream = HttpStream<TcpStream>; typedef
244 type Stream = HttpStream<MixStream>; typedef
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| D | error.rs | 32 Stream(u64, H3ErrorCode), enumerator
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| D | simple.rs | 504 Stream(Box<dyn ReusableReader + Send + Sync + Unpin>), enumerator
|