Searched refs:MixStream (Results 1 - 4 of 4) sorted by relevance
| /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>
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>
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 | mod.rs | 48 pub use ssl_stream::MixStream;
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | mix.rs | 24 pub enum MixStream { enum
34 impl AsyncRead for MixStream {
42 MixStream::Http(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
43 MixStream::Https(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
45 MixStream::Udp(s) => Pin::new(s).poll_recv(cx, buf), in poll_read()
50 impl AsyncWrite for MixStream {
58 MixStream::Http(s) => Pin::new(s).poll_write(ctx, buf), in poll_write()
59 MixStream::Https(s) => Pin::new(s).poll_write(ctx, buf), in poll_write()
61 MixStream::Udp(s) => Pin::new(s).poll_send(ctx, buf), in poll_write()
67 MixStream in poll_flush()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 209 use crate::async_impl::mix::MixStream;
220 type Stream = HttpStream<MixStream>;
268 Ok(HttpStream::new(MixStream::Http(stream), detail)) in connect()
309 HttpStream::new(MixStream::Udp(udp_socket), detail); in connect()
364 ) -> Result<HttpStream<MixStream>, HttpClientError> {
410 Ok(HttpStream::new(MixStream::Https(stream), detail))
|
Completed in 2 milliseconds