base-endpoint 0.2.0

Runtime-independent binding and connecting through Base scheduler capabilities
Documentation 
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
40
41
42
43
44
45
46

// Released under the MIT License.
// Copyright, 2026, by Samuel Williams.

use super::{RustlsConnection, establish, tls_error};
use crate::tls::TlsAcceptor;
use ::rustls::{ServerConfig, ServerConnection};
use base_scheduler::{
    Cancellation, OperationResult, SocketClose, SocketStreamReading, SocketStreamWriting,
};
use std::sync::Arc;

/// A rustls server provider using application-supplied certificates, client-authentication policy and ALPN configuration.
#[derive(Clone, Debug)]
pub struct RustlsAcceptor {
    config: Arc<ServerConfig>,
}

impl RustlsAcceptor {
    /// Share an explicitly configured rustls server configuration.
    pub fn new(config: Arc<ServerConfig>) -> Self {
        Self { config }
    }
}

impl<S> TlsAcceptor<S, S::Socket> for RustlsAcceptor
where
    S: SocketStreamReading + SocketStreamWriting + SocketClose + ?Sized,
    S::Socket: 'static,
{
    type Connection = RustlsConnection<S::Socket>;

    async fn accept(
        &self,
        scheduler: &S,
        connection: S::Socket,
        cancellation: &Cancellation,
    ) -> OperationResult<Self::Connection> {
        let state = (|| {
            cancellation.check()?;
            Ok(ServerConnection::new(self.config.clone())
                .map_err(tls_error)?
                .into())
        })();
        establish(scheduler, connection, state, cancellation).await
    }
}