You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
58 lines
1.9 KiB
58 lines
1.9 KiB
//! Convenience wrapper for streams to switch between plain TCP and TLS at runtime.
|
|
//!
|
|
//! There is no dependency on actual TLS implementations. Everything like
|
|
//! `native_tls` or `openssl` will work as long as there is a TLS stream supporting standard
|
|
//! `AsyncRead + AsyncWrite` traits.
|
|
use std::pin::Pin;
|
|
use std::task::{Context, Poll};
|
|
|
|
use futures_io::{AsyncRead, AsyncWrite};
|
|
|
|
/// Stream, either plain TCP or TLS.
|
|
#[derive(Debug)]
|
|
pub enum Stream<S, T> {
|
|
/// Unencrypted socket stream.
|
|
Plain(S),
|
|
/// Encrypted socket stream.
|
|
Tls(T),
|
|
}
|
|
|
|
impl<S: AsyncRead + Unpin, T: AsyncRead + Unpin> AsyncRead for Stream<S, T> {
|
|
fn poll_read(
|
|
self: Pin<&mut Self>,
|
|
cx: &mut Context<'_>,
|
|
buf: &mut [u8],
|
|
) -> Poll<std::io::Result<usize>> {
|
|
match self.get_mut() {
|
|
Stream::Plain(ref mut s) => Pin::new(s).poll_read(cx, buf),
|
|
Stream::Tls(ref mut s) => Pin::new(s).poll_read(cx, buf),
|
|
}
|
|
}
|
|
}
|
|
|
|
impl<S: AsyncWrite + Unpin, T: AsyncWrite + Unpin> AsyncWrite for Stream<S, T> {
|
|
fn poll_write(
|
|
self: Pin<&mut Self>,
|
|
cx: &mut Context<'_>,
|
|
buf: &[u8],
|
|
) -> Poll<Result<usize, std::io::Error>> {
|
|
match self.get_mut() {
|
|
Stream::Plain(ref mut s) => Pin::new(s).poll_write(cx, buf),
|
|
Stream::Tls(ref mut s) => Pin::new(s).poll_write(cx, buf),
|
|
}
|
|
}
|
|
|
|
fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), std::io::Error>> {
|
|
match self.get_mut() {
|
|
Stream::Plain(ref mut s) => Pin::new(s).poll_flush(cx),
|
|
Stream::Tls(ref mut s) => Pin::new(s).poll_flush(cx),
|
|
}
|
|
}
|
|
|
|
fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), std::io::Error>> {
|
|
match self.get_mut() {
|
|
Stream::Plain(ref mut s) => Pin::new(s).poll_close(cx),
|
|
Stream::Tls(ref mut s) => Pin::new(s).poll_close(cx),
|
|
}
|
|
}
|
|
}
|
|
|