Searched refs:Stream (Results 1 - 11 of 11) sorted by relevance
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
H A D | pool.rs | 31 impl<C: Connector> ConnPool<C, C::Stream> { 39 pub(crate) fn connect_to(&self, uri: Uri) -> Result<Conn<C::Stream>, HttpClientError> {
|
H A D | connector.rs | 24 type Stream: Read + Write + 'static; types 29 fn connect(&self, uri: &Uri) -> Result<Self::Stream, Self::Error>; in connect() 62 type Stream = TcpStream; types 65 fn connect(&self, uri: &Uri) -> Result<Self::Stream, Self::Error> { in connect() 87 type Stream = MixStream<TcpStream>; types 90 fn connect(&self, uri: &Uri) -> Result<Self::Stream, Self::Error> { in connect()
|
H A D | client.rs | 49 inner: ConnPool<C, C::Stream>,
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
H A D | request.rs | 242 /// - Stream: a body whose content comes from a stream. 259 Stream(Box<dyn ReusableReader + Send + Sync + Unpin>), 310 Body::new(BodyKind::Stream( in stream() 351 BodyKind::Stream(ref mut stream) => stream.reuse().await, 372 BodyKind::Stream(ref mut stream) => Pin::new(stream).poll_read(cx, buf), in poll_read()
|
H A D | pool.rs | 51 impl<C: Connector> ConnPool<C, C::Stream> { 62 pub(crate) async fn connect_to(&self, uri: &Uri) -> Result<Conn<C::Stream>, HttpClientError> { 136 C: Connector<Stream = S>, 167 C: Connector<Stream = S>, 184 C: Connector<Stream = S>, 220 C: Connector<Stream = S>, 244 C: Connector<Stream = S>, 289 C: Connector<Stream = S>,
|
H A D | client.rs | 73 inner: ConnPool<C, C::Stream>, 195 async fn connect_to(&self, uri: &Uri) -> Result<Conn<C::Stream>, HttpClientError> { 209 conn: Conn<C::Stream>,
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
H A D | streams.rs | 117 pub(crate) struct Stream { 148 pub(crate) stream_map: HashMap<StreamId, Stream>, 313 let stream = Stream::new(recv_window, send_window, headers, data); 755 impl Stream { impls
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
H A D | mod.rs | 37 type Stream: AsyncRead + AsyncWrite + ConnInfo + Unpin + Sync + Send + 'static; types 40 type Future: Future<Output = Result<Self::Stream, HttpClientError>> 159 type Stream = HttpStream<TcpStream>; types 161 Pin<Box<dyn Future<Output = Result<Self::Stream, HttpClientError>> + Sync + Send>>; 220 type Stream = HttpStream<MixStream>; types 222 Pin<Box<dyn Future<Output = Result<Self::Stream, HttpClientError>> + Sync + Send>>;
|
/commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
H A D | error.rs | 31 /// Stream level error. 32 Stream(u64, H3ErrorCode), 93 /// Stream creation error. 113 /// Stream terminated early.
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
H A D | stream_manager.rs | 14 //! Stream Manager module. 291 DispatchErrorKind::H3(H3Error::Stream(id, H3ErrorCode::H3InternalError)) 451 return Err(DispatchErrorKind::H3(H3Error::Stream(id, err.into()))); in read_stream() 486 // MAX_PUSH_ID not send, Push Stream means error in process_recv_data() 653 DispatchErrorKind::H3(H3Error::Stream(id, e)) => { in handle_error()
|
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
H A D | simple.rs | 430 MultiPartState::Stream(stream) => { 463 MultiPartState::Stream(stream) => { in poll_read_curr() 504 Stream(Box<dyn ReusableReader + Send + Sync + Unpin>), 513 Self::Stream(reader) in stream() 522 // Cant not compare Stream, Should not do this. in eq() 523 (Self::Stream(l0), Self::Stream(r0)) => core::ptr::eq(l0, r0), in eq() 534 Self::Stream(arg0) => f.debug_tuple("Stream").field(&(arg0 as *const _)).finish(), in fmt()
|
Completed in 10 milliseconds