Home
last modified time | relevance | path

Searched refs:Stream (Results 1 - 11 of 11) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
H A Dpool.rs31 impl<C: Connector> ConnPool<C, C::Stream> {
39 pub(crate) fn connect_to(&self, uri: Uri) -> Result<Conn<C::Stream>, HttpClientError> {
H A Dconnector.rs24 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 Dclient.rs49 inner: ConnPool<C, C::Stream>,
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Drequest.rs242 /// - 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 Dpool.rs51 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 Dclient.rs73 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 Dstreams.rs117 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 Dmod.rs37 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 Derror.rs31 /// 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 Dstream_manager.rs14 //! 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 Dsimple.rs430 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