Searched refs:MixStream (Results 1 – 6 of 6) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | mix.rs | 21 pub enum MixStream<T> { enum
28 impl<T> AsyncRead for MixStream<T> implementation
39 MixStream::Http(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
40 MixStream::Https(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
45 impl<T> AsyncWrite for MixStream<T> implementation
56 MixStream::Http(s) => Pin::new(s).poll_write(ctx, buf), in poll_write()
57 MixStream::Https(s) => Pin::new(s).poll_write(ctx, buf), in poll_write()
63 MixStream::Http(s) => Pin::new(s).poll_flush(ctx), in poll_flush()
64 MixStream::Https(s) => Pin::new(s).poll_flush(ctx), in poll_flush()
70 MixStream::Http(s) => Pin::new(s).poll_shutdown(ctx), in poll_shutdown()
[all …]
|
| H A D | mod.rs | 21 pub use mix::MixStream;
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | ssl_stream.rs | 20 pub enum MixStream<T> { enum
27 impl<T> Read for MixStream<T> implementation
33 MixStream::Http(s) => s.read(buf), in read()
34 MixStream::Https(s) => s.read(buf), in read()
38 impl<T> Write for MixStream<T> implementation
44 MixStream::Http(s) => s.write(buf), in write()
45 MixStream::Https(s) => s.write(buf), in write()
51 MixStream::Http(s) => s.flush(), in flush()
52 MixStream::Https(s) => s.flush(), in flush()
|
| H A D | connector.rs | 83 use crate::sync_impl::{Connector, MixStream};
87 type Stream = MixStream<TcpStream>;
116 Ok(MixStream::Http(TcpStream::connect(addr).map_err(|e| { in connect()
140 Ok(MixStream::Https(stream)) in connect()
|
| H A D | mod.rs | 48 pub use ssl_stream::MixStream;
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 189 use crate::async_impl::ssl_stream::{AsyncSslStream, MixStream};
196 type Stream = HttpStream<MixStream<TcpStream>>;
244 Ok(HttpStream::new(MixStream::Http(stream), detail)) in connect()
289 ) -> Result<HttpStream<MixStream<TcpStream>>, HttpClientError> { in https_connect()
335 Ok(HttpStream::new(MixStream::Https(stream), detail)) in https_connect()
|