pelikan-net 0.2.0

Pelikan project's networking abstractions for non-blocking event loops
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

// Copyright 2022 Twitter, Inc.
// Licensed under the Apache License, Version 2.0
// http://www.apache.org/licenses/LICENSE-2.0

use crate::*;

pub struct Connector {
    inner: ConnectorType,
}

enum ConnectorType {
    Tcp(TcpConnector),
    #[cfg(any(feature = "boringssl", feature = "openssl"))]
    TlsTcp(TlsTcpConnector),
}

impl Connector {
    /// Attemps to connect to the provided address.
    pub fn connect<A: ToSocketAddrs>(&self, addr: A) -> Result<Stream> {
        match &self.inner {
            ConnectorType::Tcp(connector) => Ok(Stream::from(connector.connect(addr)?)),
            #[cfg(any(feature = "boringssl", feature = "openssl"))]
            ConnectorType::TlsTcp(connector) => Ok(Stream::from(connector.connect(addr)?)),
        }
    }
}

impl From<TcpConnector> for Connector {
    fn from(other: TcpConnector) -> Self {
        Self {
            inner: ConnectorType::Tcp(other),
        }
    }
}

#[cfg(any(feature = "boringssl", feature = "openssl"))]
impl From<TlsTcpConnector> for Connector {
    fn from(other: TlsTcpConnector) -> Self {
        Self {
            inner: ConnectorType::TlsTcp(other),
        }
    }
}