wtx 0.28.0

A collection of different transport implementations and related tools focused primarily on web technologies.
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

use crate::{
  http::{
    client_pool::{ClientPool, ClientPoolRM, NoAuxFn},
    conn_params::ConnParams,
  },
  misc::Lock,
  pool::{ResourceManager, SimplePool, SimplePoolResource},
};
use core::marker::PhantomData;

/// Allows the customization of parameters that control HTTP requests and responses.
#[derive(Debug)]
pub struct ClientPoolBuilder<F, RL, S> {
  cp: ConnParams,
  fun: F,
  len: usize,
  phantom: PhantomData<(RL, S)>,
}

impl<F, RL, S> ClientPoolBuilder<F, RL, S> {
  /// Auxiliary structure returned by a function.
  #[inline]
  pub fn aux<NF>(self, fun: NF) -> ClientPoolBuilder<NF, RL, S> {
    ClientPoolBuilder { cp: self.cp, fun, len: self.len, phantom: self.phantom }
  }

  _conn_params_methods!();
}

impl<RL, S> ClientPoolBuilder<NoAuxFn, RL, S> {
  #[inline]
  pub(crate) fn _no_aux_fun(len: usize) -> Self {
    fn fun() {}
    Self { cp: ConnParams::default(), fun, len, phantom: PhantomData }
  }
}

impl<F, RL, S> ClientPoolBuilder<F, RL, S>
where
  RL: Lock<Resource = SimplePoolResource<<ClientPoolRM<F, S> as ResourceManager>::Resource>>,
  for<'any> F: 'any,
  for<'any> RL: 'any,
  for<'any> S: 'any,
  ClientPoolRM<F, S>: ResourceManager,
{
  /// Creates a new client with inner parameters.
  #[inline]
  pub fn build(self) -> ClientPool<RL, ClientPoolRM<F, S>> {
    ClientPool {
      pool: SimplePool::new(
        self.len,
        ClientPoolRM { _cp: self.cp, _fun: self.fun, _phantom: PhantomData },
      ),
    }
  }
}