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
57
58
59
60
61
62
63
64

//! Pool Manager

mod resource_manager;
#[cfg(feature = "std")]
mod simple_pool;

use core::future::Future;
#[cfg(feature = "postgres")]
pub use resource_manager::database::PostgresRM;
pub use resource_manager::{ResourceManager, SimpleRM};
#[cfg(feature = "std")]
pub use simple_pool::*;

/// Manages HTTP/2 resources for clients and servers.
#[cfg(feature = "http2")]
pub type Http2BufferRM = SimpleRM<fn() -> crate::Result<crate::http2::Http2Buffer>>;
/// Manages resources for HTTP2 requests and responses.
#[cfg(feature = "http2")]
pub type StreamBufferRM = SimpleRM<fn() -> crate::Result<crate::http::ReqResBuffer>>;
/// Manages WebSocket resources.
#[cfg(feature = "web-socket")]
pub type WebSocketRM = SimpleRM<fn() -> crate::Result<crate::web_socket::WebSocketBuffer>>;

/// A pool contains a set of resources that are behind some synchronism mechanism.
pub trait Pool {
  /// Element returned by [`Pool::get`].
  type GetElem<'this>
  where
    Self: 'this;
  /// See [`ResourceManager`].
  type ResourceManager: ResourceManager;

  /// Tries to retrieve a free resource.
  ///
  /// If the resource does not exist, a new one is created and if the pool is full, this method will
  /// await until a free resource is available.
  fn get<'this>(
    &'this self,
    ca: &<Self::ResourceManager as ResourceManager>::CreateAux,
    ra: &<Self::ResourceManager as ResourceManager>::RecycleAux,
  ) -> impl Future<
    Output = Result<Self::GetElem<'this>, <Self::ResourceManager as ResourceManager>::Error>,
  >;
}

impl<T> Pool for &T
where
  T: Pool,
{
  type GetElem<'this>
    = T::GetElem<'this>
  where
    Self: 'this;
  type ResourceManager = T::ResourceManager;

  #[inline]
  async fn get<'this>(
    &'this self,
    ca: &<Self::ResourceManager as ResourceManager>::CreateAux,
    ra: &<Self::ResourceManager as ResourceManager>::RecycleAux,
  ) -> Result<Self::GetElem<'this>, <Self::ResourceManager as ResourceManager>::Error> {
    (**self).get(ca, ra).await
  }
}