wtx 0.52.1

A collection of different transport implementations and related tools focused primarily on web technologies.
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

use crate::{
  collections::SingleTypeStorage,
  executor::Executor,
  misc::Lease,
  net::{TcpParams, TcpStream as _, Uri},
  tls::{TlsConfig, TlsConnector},
};

/// Builds [`TlsConnector`].
#[derive(Debug)]
pub struct TlsConnectorBuilder<EX, U> {
  _executor: EX,
  tcp_params: TcpParams,
  uri: U,
}

#[cfg(feature = "std")]
impl<STR, U> TlsConnectorBuilder<crate::executor::StdExecutor, U>
where
  STR: Lease<str>,
  U: Lease<Uri<STR>> + SingleTypeStorage<Item = STR>,
{
  /// [`Self::new`] that uses the elements provided by the standard library
  #[inline]
  pub fn std(uri: U) -> Self {
    Self::new(crate::executor::StdExecutor::default(), uri)
  }
}

#[cfg(feature = "tokio")]
impl<STR, U> TlsConnectorBuilder<crate::executor::TokioExecutor, U>
where
  STR: Lease<str>,
  U: Lease<Uri<STR>> + SingleTypeStorage<Item = STR>,
{
  /// [`Self::new`] that uses the elements provided by the tokio project
  #[inline]
  pub fn tokio(uri: U) -> Self {
    Self::new(crate::executor::TokioExecutor::default(), uri)
  }
}

impl<EX, STR, U> TlsConnectorBuilder<EX, U>
where
  EX: Executor,
  STR: Lease<str>,
  U: Lease<Uri<STR>> + SingleTypeStorage<Item = STR>,
{
  /// New instance with the minimum amount of required parameters.
  #[inline]
  pub fn new(executor: EX, uri: U) -> Self {
    Self { _executor: executor, tcp_params: TcpParams::default(), uri }
  }

  /// Transforms itself into [`TlsConnector`] according to the internal parameters.
  #[inline]
  pub async fn build<RNG, TCG, TCX>(
    self,
    config: TCG,
    rng: RNG,
  ) -> crate::Result<TlsConnector<RNG, EX::TcpStream, TCG, U>>
  where
    TCG: Lease<TlsConfig<TCX>> + SingleTypeStorage<Item = TCX>,
  {
    let addr = self.uri.lease().hostname_with_implied_port();
    let stream = EX::TcpStream::connect(addr, self.tcp_params).await?;
    Ok(TlsConnector::new(config, rng, stream, self.uri))
  }

  /// Owned version of [`Self::tcp_params`].
  #[inline]
  #[must_use]
  pub const fn set_tcp_params(mut self, value: TcpParams) -> Self {
    self.tcp_params = value;
    self
  }

  /// See [`TcpParams`].
  #[inline]
  pub const fn tcp_params(&self) -> &TcpParams {
    &self.tcp_params
  }

  /// Mutable version of [`Self::tcp_params`].
  #[inline]
  pub const fn tcp_params_mut(&mut self) -> &mut TcpParams {
    &mut self.tcp_params
  }
}