1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//! TLS support.

use futures::Future;
use std::error::Error;
use tokio_io::{AsyncRead, AsyncWrite};

pub use stream::Stream;

#[cfg(feature = "with-openssl")]
pub mod openssl;

/// A trait implemented by streams returned from `Handshake` implementations.
pub trait TlsStream: AsyncRead + AsyncWrite + Send {
    /// Returns a shared reference to the inner stream.
    fn get_ref(&self) -> &Stream;

    /// Returns a mutable reference to the inner stream.
    fn get_mut(&mut self) -> &mut Stream;
}

impl TlsStream for Stream {
    fn get_ref(&self) -> &Stream {
        self
    }

    fn get_mut(&mut self) -> &mut Stream {
        self
    }
}

/// A trait implemented by types that can manage TLS encryption for a stream.
pub trait Handshake: 'static + Sync + Send {
    /// Performs a TLS handshake, returning a wrapped stream.
    fn handshake(
        self: Box<Self>,
        host: &str,
        stream: Stream,
    ) -> Box<Future<Item = Box<TlsStream>, Error = Box<Error + Sync + Send>> + Send>;
}