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
50
51
52
53
54
55

use crate::{collection::Vector, misc::bytes_split1};
#[cfg(feature = "std")]
use std::io::BufRead;

/// Simple reader of CSV files
#[derive(Debug)]
pub struct Csv<R, S> {
  delimiter: u8,
  reader: R,
  source: S,
}

impl<R, S> Csv<R, S>
where
  R: FnMut(&mut Vector<u8>, &mut S) -> crate::Result<usize>,
{
  /// New instance
  #[inline]
  pub const fn new(delimiter: u8, reader: R, source: S) -> Self {
    Self { delimiter, reader, source }
  }

  /// Reads the next line from the source and returns an iterator over the fields.
  #[inline]
  pub fn next_line<'buffer>(
    &mut self,
    buffer: &'buffer mut Vector<u8>,
  ) -> crate::Result<Option<impl Iterator<Item = &'buffer [u8]>>> {
    buffer.clear();
    let line_len = (self.reader)(buffer, &mut self.source)?;
    if line_len == 0 {
      return Ok(None);
    }
    let line = buffer.get(..line_len).unwrap_or_default();
    Ok(Some(bytes_split1(line, self.delimiter)))
  }
}

#[cfg(feature = "std")]
impl<S> Csv<fn(&mut Vector<u8>, &mut S) -> crate::Result<usize>, S>
where
  S: BufRead,
{
  /// New instance based on [`BufRead`].
  #[inline]
  pub const fn from_buf_read(delimiter: u8, source: S) -> Self {
    fn reader<S>(buffer: &mut Vector<u8>, source: &mut S) -> crate::Result<usize>
    where
      S: BufRead,
    {
      Ok(source.read_until(b'\n', buffer.vec_mut())?)
    }
    Self { delimiter, reader, source }
  }
}