wtx 0.43.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

use crate::http2::{
  Http2Error,
  common_flags::CommonFlags,
  frame_init::{FrameInit, FrameInitTy},
  misc::{protocol_err, trim_frame_pad},
  u31::U31,
};

#[derive(Debug, Eq, PartialEq)]
pub(crate) struct DataFrame {
  cf: CommonFlags,
  data_len: U31,
  pad_len: Option<u8>,
  stream_id: U31,
}

impl DataFrame {
  pub(crate) const fn new(data_len: U31, stream_id: U31) -> Self {
    Self { cf: CommonFlags::empty(), data_len, pad_len: None, stream_id }
  }

  pub(crate) const fn bytes(&self) -> [u8; 9] {
    FrameInit::new(self.cf, self.data_len.u32(), self.stream_id, FrameInitTy::Data).bytes()
  }

  pub(crate) const fn data_len(&self) -> U31 {
    self.data_len
  }

  pub(crate) const fn has_eos(&self) -> bool {
    self.cf.has_eos()
  }

  pub(crate) fn read(mut data: &[u8], mut fi: FrameInit) -> crate::Result<(Self, &[u8])> {
    if fi.stream_id.is_zero() {
      return Err(protocol_err(Http2Error::InvalidDataFrameZeroId));
    }
    fi.cf.only_eos_pad();
    let pad_len = trim_frame_pad(fi.cf, &mut data)?;
    let Ok(data_len) = u32::try_from(data.len()).map(U31::from_u32) else {
      return Err(protocol_err(Http2Error::InvalidDataFrameDataLen));
    };
    Ok((Self { cf: fi.cf, data_len, pad_len, stream_id: fi.stream_id }, data))
  }

  pub(crate) const fn set_eos(&mut self) {
    self.cf.set_eos();
  }
}