Rename trait HttpsStream -> ReadWrite and make it public

Also provide an example of how to use it.

src/lib.rs

@@ -356,7 +356,6 @@ pub(crate) fn default_tls_config() -> std::sync::Arc<dyn TlsConnector> {
 // calls at the top of the crate (`ureq::get` etc).
 #[cfg(not(feature = "tls"))]
 pub(crate) fn default_tls_config() -> std::sync::Arc<dyn TlsConnector> {
-    use crate::stream::HttpsStream;
     use std::net::TcpStream;
     use std::sync::Arc;
 
@@ -367,7 +366,7 @@ pub(crate) fn default_tls_config() -> std::sync::Arc<dyn TlsConnector> {
             &self,
             _dns_name: &str,
             _tcp_stream: TcpStream,
-        ) -> Result<Box<dyn HttpsStream>, crate::error::Error> {
+        ) -> Result<Box<dyn ReadWrite>, crate::error::Error> {
             Err(ErrorKind::UnknownScheme
                 .msg("cannot make HTTPS request because no TLS backend is configured"))
         }
@@ -398,7 +397,7 @@ pub use crate::proxy::Proxy;
 pub use crate::request::{Request, RequestUrl};
 pub use crate::resolve::Resolver;
 pub use crate::response::Response;
-pub use crate::stream::TlsConnector;
+pub use crate::stream::{ReadWrite, TlsConnector};
 
 // re-export
 #[cfg(feature = "cookies")]

src/ntls.rs

@@ -1,6 +1,6 @@
 use crate::error::Error;
 use crate::error::ErrorKind;
-use crate::stream::{HttpsStream, TlsConnector};
+use crate::stream::{ReadWrite, TlsConnector};
 
 use std::net::TcpStream;
 use std::sync::Arc;
@@ -11,11 +11,7 @@ pub(crate) fn default_tls_config() -> std::sync::Arc<dyn TlsConnector> {
 }
 
 impl TlsConnector for native_tls::TlsConnector {
-    fn connect(
-        &self,
-        dns_name: &str,
-        tcp_stream: TcpStream,
-    ) -> Result<Box<dyn HttpsStream>, Error> {
+    fn connect(&self, dns_name: &str, tcp_stream: TcpStream) -> Result<Box<dyn ReadWrite>, Error> {
         let stream =
             native_tls::TlsConnector::connect(self, dns_name, tcp_stream).map_err(|e| {
                 ErrorKind::ConnectionFailed
@@ -28,7 +24,7 @@ impl TlsConnector for native_tls::TlsConnector {
 }
 
 #[cfg(feature = "native-tls")]
-impl HttpsStream for native_tls::TlsStream<TcpStream> {
+impl ReadWrite for native_tls::TlsStream<TcpStream> {
     fn socket(&self) -> Option<&TcpStream> {
         Some(self.get_ref())
     }

src/rtls.rs

@@ -7,7 +7,7 @@ use once_cell::sync::Lazy;
 
 use crate::ErrorKind;
 use crate::{
-    stream::{HttpsStream, TlsConnector},
+    stream::{ReadWrite, TlsConnector},
     Error,
 };
 
@@ -28,7 +28,7 @@ fn is_close_notify(e: &std::io::Error) -> bool {
 
 struct RustlsStream(rustls::StreamOwned<rustls::ClientConnection, TcpStream>);
 
-impl HttpsStream for RustlsStream {
+impl ReadWrite for RustlsStream {
     fn socket(&self) -> Option<&TcpStream> {
         Some(self.0.get_ref())
     }
@@ -94,7 +94,7 @@ impl TlsConnector for Arc<rustls::ClientConfig> {
         &self,
         dns_name: &str,
         mut tcp_stream: TcpStream,
-    ) -> Result<Box<dyn HttpsStream>, Error> {
+    ) -> Result<Box<dyn ReadWrite>, Error> {
         let sni = rustls::ServerName::try_from(dns_name)
             .map_err(|e| ErrorKind::Dns.msg(format!("parsing '{}'", dns_name)).src(e))?;
 

src/stream.rs

@@ -17,7 +17,8 @@ use crate::{error::Error, proxy::Proto};
 use crate::error::ErrorKind;
 use crate::unit::Unit;
 
-pub trait HttpsStream: Read + Write + Send + Sync + 'static {
+/// Trait for things implementing [std::io::Read] + [std::io::Write]. Used in [TlsConnector].
+pub trait ReadWrite: Read + Write + Send + Sync + 'static {
     fn socket(&self) -> Option<&TcpStream>;
 }
 
@@ -26,7 +27,7 @@ pub trait TlsConnector: Send + Sync {
         &self,
         dns_name: &str,
         tcp_stream: TcpStream,
-    ) -> Result<Box<dyn HttpsStream>, crate::error::Error>;
+    ) -> Result<Box<dyn ReadWrite>, crate::error::Error>;
 }
 
 pub(crate) struct Stream {
@@ -41,19 +42,19 @@ trait Inner: Read + Write {
     }
 }
 
-impl<T: HttpsStream + ?Sized> HttpsStream for Box<T> {
+impl<T: ReadWrite + ?Sized> ReadWrite for Box<T> {
     fn socket(&self) -> Option<&TcpStream> {
-        HttpsStream::socket(self.as_ref())
+        ReadWrite::socket(self.as_ref())
     }
 }
 
-impl<T: HttpsStream> Inner for T {
+impl<T: ReadWrite> Inner for T {
     fn is_poolable(&self) -> bool {
         true
     }
 
     fn socket(&self) -> Option<&TcpStream> {
-        HttpsStream::socket(self)
+        ReadWrite::socket(self)
     }
 }