buffer-redux 1.1.0

Drop-in replacements for buffered I/O in `std::io` with extra features.
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120

#![allow(missing_docs)]

mod std_buf;

#[cfg(feature = "slice-deque")]
mod slice_deque_buf;

use std::mem::MaybeUninit;

use self::std_buf::StdBuf;

#[cfg(feature = "slice-deque")]
use self::slice_deque_buf::SliceDequeBuf;

pub enum BufImpl {
    Std(StdBuf),
    #[cfg(feature = "slice-deque")]
    Ringbuf(SliceDequeBuf),
}

macro_rules! forward_method {
    ($(#[$m:meta])*
     pub fn $fnname:ident(&self $($args:tt)*) [$($passargs:tt)*] $(-> $ret:ty)*) => {
        $(#[$m])*
        pub fn $fnname(&self $($args)*) $(-> $ret)* {
            match *self {
                BufImpl::Std(ref buf) => buf.$fnname($($passargs)*),
                #[cfg(feature = "slice-deque")]
                BufImpl::Ringbuf(ref buf) => buf.$fnname($($passargs)*),
            }
        }
    };

    ($(#[$m:meta])*
     pub fn $fnname:ident(&mut self $($args:tt)*) [$($passargs:tt)*] $(-> $ret:ty)*) => {
        $(#[$m])*
        pub fn $fnname(&mut self $($args)*) $(-> $ret)* {
            match *self {
                BufImpl::Std(ref mut buf) => buf.$fnname($($passargs)*),
                #[cfg(feature = "slice-deque")]
                BufImpl::Ringbuf(ref mut buf) => buf.$fnname($($passargs)*),
            }
        }
    };

    ($(#[$m:meta])*
     pub unsafe fn $fnname:ident(&self $($args:tt)*) [$($passargs:tt)*] $(-> $ret:ty)*) => {
        $(#[$m])*
        pub unsafe fn $fnname(&self $($args)*) $(-> $ret)* {
            match *self {
                BufImpl::Std(ref buf) => buf.$fnname($($passargs)*),
                #[cfg(feature = "slice-deque")]
                BufImpl::Ringbuf(ref buf) => buf.$fnname($($passargs)*),
            }
        }
    };

    ($(#[$m:meta])*
     pub unsafe fn $fnname:ident(&mut self $($args:tt)*) [$($passargs:tt)*] $(-> $ret:ty)*) => {
        $(#[$m])*
        pub unsafe fn $fnname(&mut self $($args)*) $(-> $ret)* {
            match *self {
                BufImpl::Std(ref mut buf) => buf.$fnname($($passargs)*),
                #[cfg(feature = "slice-deque")]
                BufImpl::Ringbuf(ref mut buf) => buf.$fnname($($passargs)*),
            }
        }
    };
}

macro_rules! forward_methods {
    ($($(#[$m:meta])*
     $($qualifiers:ident)+ ($($args:tt)*) [$($passargs:tt)*] $(-> $ret:ty)*);+;) => (
        $(forward_method! {
            $(#[$m])* $($qualifiers)+ ($($args)*) [$($passargs)*] $(-> $ret)*
        })*
    )
}

impl BufImpl {
    pub fn with_capacity(cap: usize) -> Self {
        BufImpl::Std(StdBuf::with_capacity(cap))
    }

    #[cfg(feature = "slice-deque")]
    pub fn with_capacity_ringbuf(cap: usize) -> Self {
        BufImpl::Ringbuf(SliceDequeBuf::with_capacity(cap))
    }

    pub fn is_ringbuf(&self) -> bool {
        match *self {
            #[cfg(feature = "slice-deque")]
            BufImpl::Ringbuf(_) => true,
            _ => false,
        }
    }

    forward_methods! {
        pub fn capacity(&self)[] -> usize;

        pub fn len(&self)[] -> usize;

        pub fn usable_space(&self)[] -> usize;

        pub fn reserve(&mut self, additional: usize)[additional] -> bool;

        pub fn make_room(&mut self)[];

        #[inline]
        pub fn buf(&self)[] -> &[u8];

        pub fn buf_mut(&mut self)[] -> &mut [u8];

        pub unsafe fn write_buf(&mut self)[] -> &mut [MaybeUninit<u8>];

        pub unsafe fn bytes_written(&mut self, add: usize)[add];

        pub fn consume(&mut self, amt: usize)[amt];
    }
}