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

use crate::{
  codec::Encode,
  database::client::mysql::{
    misc::packet_header,
    mysql_executor::MAX_PAYLOAD,
    protocol::{Protocol, encode_wrapper_protocol::EncodeWrapperProtocol},
  },
  misc::Usize,
  stream::Stream,
};
use core::marker::PhantomData;

pub(crate) struct PacketReq<E, T>(pub(crate) T, pub(crate) PhantomData<E>);

impl<E, T> PacketReq<E, T>
where
  E: From<crate::Error>,
  T: Encode<Protocol<(), E>>,
{
  pub(crate) async fn send<S>(
    &self,
    ew: &mut EncodeWrapperProtocol<'_>,
    sequence_id: &mut u8,
    stream: &mut S,
  ) -> Result<(), E>
  where
    S: Stream,
  {
    let mut chunks = ew.encode_buffer.chunks_exact(*Usize::from(MAX_PAYLOAD));
    for chunk in chunks.by_ref() {
      let header = packet_header(chunk.len(), sequence_id);
      stream.write_all_vectored(&[header.as_slice(), chunk]).await?;
    }
    let chunk = chunks.remainder();
    let header = packet_header(chunk.len(), sequence_id);
    stream.write_all_vectored(&[header.as_slice(), chunk]).await?;
    Ok(())
  }
}