Struct tokio_rustls::LazyConfigAcceptor

pub struct LazyConfigAcceptor<IO> {
    pub(crate) acceptor: Acceptor,
    pub(crate) io: Option<IO>,
}

Fields

acceptor: Acceptor

io: Option<IO>

Implementations

impl<IO> LazyConfigAcceptor<IO>

where IO: AsyncRead + AsyncWrite + Unpin,

pub fn new(acceptor: Acceptor, io: IO) -> Self

pub fn take_io(&mut self) -> Option<IO>

Takes back the client connection. Will return None if called more than once or if the connection has been accepted.

Example

use tokio::io::AsyncWriteExt;
let listener = tokio::net::TcpListener::bind("127.0.0.1:4443").await.unwrap();
let (stream, _) = listener.accept().await.unwrap();

let acceptor = tokio_rustls::LazyConfigAcceptor::new(rustls::server::Acceptor::default(), stream);
futures_util::pin_mut!(acceptor);

match acceptor.as_mut().await {
    Ok(start) => {
        let clientHello = start.client_hello();
        let config = choose_server_config(clientHello);
        let stream = start.into_stream(config).await.unwrap();
        // Proceed with handling the ServerConnection...
    }
    Err(err) => {
        if let Some(mut stream) = acceptor.take_io() {
            stream
                .write_all(
                    format!("HTTP/1.1 400 Invalid Input\r\n\r\n\r\n{:?}\n", err)
                        .as_bytes()
                )
                .await
                .unwrap();
        }
    }
}

Trait Implementations

impl<IO> Future for LazyConfigAcceptor<IO>

where IO: AsyncRead + AsyncWrite + Unpin,

type Output = Result<StartHandshake<IO>, Error>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.