rseip-core 0.1.3

core module for rseip
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

// rseip
//
// rseip - Ethernet/IP (CIP) in pure Rust.
// Copyright: 2021, Joylei <leingliu@gmail.com>
// License: MIT

use super::*;

pub struct SliceContainer<'a, T> {
    inner: &'a [T],
    bytes_count: Option<usize>,
}

impl<'a, T> SliceContainer<'a, T> {
    #[inline]
    pub fn new(inner: &'a [T]) -> Self {
        Self {
            inner,
            bytes_count: None,
        }
    }

    /// fast path to compute number of bytes
    #[inline]
    pub fn with_bytes_count(mut self, size: usize) -> Self {
        self.bytes_count = Some(size);
        self
    }
}

impl<'a, T> Encode for SliceContainer<'a, T>
where
    T: Encode,
{
    #[inline]
    fn encode_by_ref<A: Encoder>(
        &self,
        buf: &mut BytesMut,
        encoder: &mut A,
    ) -> Result<(), A::Error> {
        for item in self.inner.iter() {
            item.encode_by_ref(buf, encoder)?;
        }
        Ok(())
    }

    #[inline]
    fn bytes_count(&self) -> usize {
        if let Some(v) = self.bytes_count {
            v
        } else {
            self.inner.iter().map(|v| v.bytes_count()).sum()
        }
    }
}