ps-buffer 0.1.0-21

aligned heap buffer
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

use crate::{Buffer, BufferError, SharedBuffer};

pub trait ByteIteratorIntoSharedBuffer {
    /// Collects this [`Iterator`] into a [`SharedBuffer`].
    /// # Errors
    /// [`BufferError`] is returned if an allocation or reallocation fails.
    fn into_shared_buffer(self) -> Result<SharedBuffer, BufferError>;
}

impl<T: Iterator<Item = u8>> ByteIteratorIntoSharedBuffer for T {
    fn into_shared_buffer(self) -> Result<SharedBuffer, BufferError> {
        let mut buffer = Buffer::with_capacity(self.size_hint().0)?;

        for byte in self {
            buffer.push(byte)?;
        }

        Ok(buffer.share())
    }
}

pub trait ByteRefIteratorIntoSharedBuffer {
    /// Collects this [`Iterator`] into a [`SharedBuffer`].
    /// # Errors
    /// [`BufferError`] is returned if an allocation or reallocation fails.
    fn into_shared_buffer(self) -> Result<SharedBuffer, BufferError>;
}

impl<'lt, T: Iterator<Item = &'lt u8>> ByteRefIteratorIntoSharedBuffer for T {
    fn into_shared_buffer(self) -> Result<SharedBuffer, BufferError> {
        self.copied().into_shared_buffer()
    }
}

pub trait ByteSliceIteratorIntoSharedBuffer {
    /// Collects this [`Iterator`] into a [`SharedBuffer`].
    /// # Errors
    /// [`BufferError`] is returned if an allocation or reallocation fails.
    fn into_shared_buffer(self) -> Result<SharedBuffer, BufferError>;
}

impl<Ts: AsRef<[u8]>, Ti: Iterator<Item = Ts>> ByteSliceIteratorIntoSharedBuffer for Ti {
    fn into_shared_buffer(self) -> Result<SharedBuffer, BufferError> {
        let mut buffer = Buffer::new();

        for bytes in self {
            buffer.extend_from_slice(bytes.as_ref())?;
        }

        Ok(buffer.share())
    }
}