wtx 0.45.0

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

use crate::{
  http::{HttpRecvParams, u31::U31},
  http2::{Http2Buffer, http_send_params::HttpSendParams, window::Windows},
  misc::{Lease, LeaseMut},
};

/// Internal resource used in every new instance of `Http2`.
#[derive(Debug)]
pub struct Http2Data<HB, const IS_CLIENT: bool> {
  frame_reader_error: Option<crate::Error>,
  hb: HB,
  hp: HttpRecvParams,
  hps: HttpSendParams,
  last_stream_id: U31,
  recv_streams_num: u32,
  windows: Windows,
}

impl<HB, const IS_CLIENT: bool> Http2Data<HB, IS_CLIENT>
where
  HB: LeaseMut<Http2Buffer>,
{
  pub(crate) fn new(hb: HB, hp: HttpRecvParams) -> Self {
    let hps = HttpSendParams::default();
    let windows = Windows::initial(&hp, &hps);
    Self {
      frame_reader_error: None,
      hb,
      hp,
      hps,
      last_stream_id: if IS_CLIENT { U31::ONE } else { U31::ZERO },
      recv_streams_num: 0,
      windows,
    }
  }

  pub(crate) fn parts_mut(&mut self) -> Http2DataPartsMut<'_, IS_CLIENT> {
    Http2DataPartsMut {
      frame_reader_error: &mut self.frame_reader_error,
      hb: self.hb.lease_mut(),
      hp: &mut self.hp,
      hps: &mut self.hps,
      last_stream_id: &mut self.last_stream_id,
      recv_streams_num: &mut self.recv_streams_num,
      windows: &mut self.windows,
    }
  }
}

impl<HB, const IS_CLIENT: bool> Lease<Http2Data<HB, IS_CLIENT>> for Http2Data<HB, IS_CLIENT> {
  #[inline]
  fn lease(&self) -> &Http2Data<HB, IS_CLIENT> {
    self
  }
}

impl<HB, const IS_CLIENT: bool> LeaseMut<Http2Data<HB, IS_CLIENT>> for Http2Data<HB, IS_CLIENT> {
  #[inline]
  fn lease_mut(&mut self) -> &mut Http2Data<HB, IS_CLIENT> {
    self
  }
}

pub(crate) struct Http2DataPartsMut<'instance, const IS_CLIENT: bool> {
  pub(crate) frame_reader_error: &'instance mut Option<crate::Error>,
  pub(crate) hb: &'instance mut Http2Buffer,
  pub(crate) hp: &'instance mut HttpRecvParams,
  pub(crate) hps: &'instance mut HttpSendParams,
  pub(crate) last_stream_id: &'instance mut U31,
  pub(crate) recv_streams_num: &'instance mut u32,
  pub(crate) windows: &'instance mut Windows,
}