fix(transport): Add Connected impl for TcpStream (#245)
This commit is contained in:
committed by
Lucio Franco
parent
6de0b4d26f
commit
cfdf0aff54
@@ -1,6 +1,7 @@
|
|||||||
use crate::transport::Certificate;
|
use crate::transport::Certificate;
|
||||||
use hyper::server::conn::AddrStream;
|
use hyper::server::conn::AddrStream;
|
||||||
use std::net::SocketAddr;
|
use std::net::SocketAddr;
|
||||||
|
use tokio::net::TcpStream;
|
||||||
#[cfg(feature = "tls")]
|
#[cfg(feature = "tls")]
|
||||||
use tokio_rustls::{rustls::Session, server::TlsStream};
|
use tokio_rustls::{rustls::Session, server::TlsStream};
|
||||||
|
|
||||||
@@ -27,6 +28,12 @@ impl Connected for AddrStream {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
impl Connected for TcpStream {
|
||||||
|
fn remote_addr(&self) -> Option<SocketAddr> {
|
||||||
|
self.peer_addr().ok()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
#[cfg(feature = "tls")]
|
#[cfg(feature = "tls")]
|
||||||
impl<T: Connected> Connected for TlsStream<T> {
|
impl<T: Connected> Connected for TlsStream<T> {
|
||||||
fn remote_addr(&self) -> Option<SocketAddr> {
|
fn remote_addr(&self) -> Option<SocketAddr> {
|
||||||
|
|||||||
Reference in New Issue
Block a user