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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297

#[cfg(feature = "async_signed")]
macro_rules! read_signed_future {
    ($primitive: ty, $future: ident, $poll_func: ident, $struct_buf: ident, $internal_struct: ident) => {
        #[derive(Debug)]
        struct $struct_buf {
            internal: $internal_struct,
        }
        impl $struct_buf {
            fn new() -> Self {
                Self { internal: $internal_struct::new() }
            }
            fn reset(&mut self) {
                self.internal.reset();
            }
        }
        $crate::pin_project_lite::pin_project! {
            #[derive(Debug)]
            #[project(!Unpin)]
            #[must_use = "futures do nothing unless you `.await` or poll them"]
            pub struct $future<'a, R: ?Sized> {
                #[pin]
                reader: &'a mut R,
                inner: $struct_buf,
            }
        }
        impl<'a, R: $crate::AsyncVariableReadable + Unpin+ ?Sized> std::future::Future for $future<'a, R> {
            type Output = std::io::Result<$primitive>;

            fn poll(self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>) -> std::task::Poll<Self::Output> {
                let mut me = self.project();
                R::$poll_func(Pin::new(&mut *me.reader), cx, me.inner)
            }
        }
    };
}
#[cfg(feature = "async_signed")]
macro_rules! read_signed_poll {
    ($primitive: ty, $poll_func: ident, $poll_internal: ident, $struct_buf: ident) => {
        #[inline]
        fn $poll_func(self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>, inner: &mut $struct_buf) -> std::task::Poll<std::io::Result<$primitive>> {
            use $crate::util::zigzag::Zigzag;
            let varint = ready!(self.$poll_internal(cx, &mut inner.internal))?;
            Poll::Ready(Ok(varint.zigzag() as $primitive))
        }
    };
}
#[cfg(feature = "async_signed")]
macro_rules! read_signed_func {
    ($func: ident, $future: ident, $struct_buf: ident) => {
        #[inline]
        fn $func(&mut self) -> $future<Self> where Self: Unpin {
            $future { reader: self, inner: $struct_buf::new() }
        }
    };
}
#[cfg(all(feature = "async_varint_size", feature = "async_signed"))]
macro_rules! read_signed_size_future {
    ($future: ident, $poll_func: ident, $struct_buf: ident, $internal_struct: ident) => {
        read_signed_future!(isize, $future, $poll_func, $struct_buf, $internal_struct);
    };
}
#[cfg(all(feature = "async_varint_size", feature = "async_signed"))]
macro_rules! read_signed_size_poll {
    ($poll_func: ident, $poll_internal: ident, $struct_buf: ident) => {
        read_signed_poll!(isize, $poll_func, $poll_internal, $struct_buf);
    };
}
#[cfg(all(feature = "async_varint_size", feature = "async_signed"))]
macro_rules! read_signed_size_func {
    ($func: ident, $future: ident, $struct_buf: ident) => {
        read_signed_func!($func, $future, $struct_buf);
    };
}
#[cfg(feature = "async_signed")]
macro_rules! define_read_signed_futures {
    () => {
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i8, ReadI8Varint, poll_read_i8_varint, InternalReadI8Varint, InternalReadU8Varint);

        read_signed_future!(i16, ReadI16Varint, poll_read_i16_varint, InternalReadI16Varint, InternalReadU16Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i16, ReadI16Varint2Le, poll_read_i16_varint_2_le, InternalReadI16Varint2Le, InternalReadU16Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i16, ReadI16Varint2Be, poll_read_i16_varint_2_be, InternalReadI16Varint2Be, InternalReadU16Varint2Be);

        read_signed_future!(i32, ReadI32Varint, poll_read_i32_varint, InternalReadI32Varint, InternalReadU32Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i32, ReadI32Varint2Le, poll_read_i32_varint_2_le, InternalReadI32Varint2Le, InternalReadU32Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i32, ReadI32Varint2Be, poll_read_i32_varint_2_be, InternalReadI32Varint2Be, InternalReadU32Varint2Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i32, ReadI32Varint4Le, poll_read_i32_varint_4_le, InternalReadI32Varint4Le, InternalReadU32Varint4Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i32, ReadI32Varint4Be, poll_read_i32_varint_4_be, InternalReadI32Varint4Be, InternalReadU32Varint4Be);

        read_signed_future!(i64, ReadI64Varint, poll_read_i64_varint, InternalReadI64Varint, InternalReadU64Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i64, ReadI64Varint2Le, poll_read_i64_varint_2_le, InternalReadI64Varint2Le, InternalReadU64Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i64, ReadI64Varint2Be, poll_read_i64_varint_2_be, InternalReadI64Varint2Be, InternalReadU64Varint2Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i64, ReadI64Varint4Le, poll_read_i64_varint_4_le, InternalReadI64Varint4Le, InternalReadU64Varint4Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i64, ReadI64Varint4Be, poll_read_i64_varint_4_be, InternalReadI64Varint4Be, InternalReadU64Varint4Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i64, ReadI64Varint8Le, poll_read_i64_varint_8_le, InternalReadI64Varint8Le, InternalReadU64Varint8Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i64, ReadI64Varint8Be, poll_read_i64_varint_8_be, InternalReadI64Varint8Be, InternalReadU64Varint8Be);

        read_signed_future!(i128, ReadI128Varint, poll_read_i128_varint, InternalReadI128Varint, InternalReadU128Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i128, ReadI128Varint2Le, poll_read_i128_varint_2_le, InternalReadI128Varint2Le, InternalReadU128Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i128, ReadI128Varint2Be, poll_read_i128_varint_2_be, InternalReadI128Varint2Be, InternalReadU128Varint2Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i128, ReadI128Varint4Le, poll_read_i128_varint_4_le, InternalReadI128Varint4Le, InternalReadU128Varint4Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i128, ReadI128Varint4Be, poll_read_i128_varint_4_be, InternalReadI128Varint4Be, InternalReadU128Varint4Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i128, ReadI128Varint8Le, poll_read_i128_varint_8_le, InternalReadI128Varint8Le, InternalReadU128Varint8Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i128, ReadI128Varint8Be, poll_read_i128_varint_8_be, InternalReadI128Varint8Be, InternalReadU128Varint8Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i128, ReadI128Varint16Le, poll_read_i128_varint_16_le, InternalReadI128Varint16Le, InternalReadU128Varint16Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_future!(i128, ReadI128Varint16Be, poll_read_i128_varint_16_be, InternalReadI128Varint16Be, InternalReadU128Varint16Be);

        #[cfg(feature = "async_varint_size")]
        read_signed_size_future!(ReadIsizeVarint, poll_read_isize_varint, InternalReadIsizeVarint, InternalReadUsizeVarint);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_future!(ReadIsizeVarint2Le, poll_read_isize_varint_2_le, InternalReadIsizeVarint2Le, InternalReadUsizeVarint2Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_future!(ReadIsizeVarint2Be, poll_read_isize_varint_2_be, InternalReadIsizeVarint2Be, InternalReadUsizeVarint2Be);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_future!(ReadIsizeVarint4Le, poll_read_isize_varint_4_le, InternalReadIsizeVarint4Le, InternalReadUsizeVarint4Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_future!(ReadIsizeVarint4Be, poll_read_isize_varint_4_be, InternalReadIsizeVarint4Be, InternalReadUsizeVarint4Be);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_future!(ReadIsizeVarint8Le, poll_read_isize_varint_8_le, InternalReadIsizeVarint8Le, InternalReadUsizeVarint8Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_future!(ReadIsizeVarint8Be, poll_read_isize_varint_8_be, InternalReadIsizeVarint8Be, InternalReadUsizeVarint8Be);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_future!(ReadIsizeVarint16Le, poll_read_isize_varint_16_le, InternalReadIsizeVarint16Le, InternalReadUsizeVarint16Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_future!(ReadIsizeVarint16Be, poll_read_isize_varint_16_be, InternalReadIsizeVarint16Be, InternalReadUsizeVarint16Be);
    };
}
#[cfg(feature = "async_signed")]
macro_rules! define_read_signed_poll {
    () => {
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i8, poll_read_i8_varint, poll_read_u8_varint, InternalReadI8Varint);

        read_signed_poll!(i16, poll_read_i16_varint, poll_read_u16_varint, InternalReadI16Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i16, poll_read_i16_varint_2_le, poll_read_u16_varint_2_le, InternalReadI16Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i16, poll_read_i16_varint_2_be, poll_read_u16_varint_2_be, InternalReadI16Varint2Be);

        read_signed_poll!(i32, poll_read_i32_varint, poll_read_u32_varint, InternalReadI32Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i32, poll_read_i32_varint_2_le, poll_read_u32_varint_2_le, InternalReadI32Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i32, poll_read_i32_varint_2_be, poll_read_u32_varint_2_be, InternalReadI32Varint2Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i32, poll_read_i32_varint_4_le, poll_read_u32_varint_4_le, InternalReadI32Varint4Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i32, poll_read_i32_varint_4_be, poll_read_u32_varint_4_be, InternalReadI32Varint4Be);

        read_signed_poll!(i64, poll_read_i64_varint, poll_read_u64_varint, InternalReadI64Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i64, poll_read_i64_varint_2_le, poll_read_u64_varint_2_le, InternalReadI64Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i64, poll_read_i64_varint_2_be, poll_read_u64_varint_2_be, InternalReadI64Varint2Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i64, poll_read_i64_varint_4_le, poll_read_u64_varint_4_le, InternalReadI64Varint4Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i64, poll_read_i64_varint_4_be, poll_read_u64_varint_4_be, InternalReadI64Varint4Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i64, poll_read_i64_varint_8_le, poll_read_u64_varint_8_le, InternalReadI64Varint8Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i64, poll_read_i64_varint_8_be, poll_read_u64_varint_8_be, InternalReadI64Varint8Be);

        read_signed_poll!(i128, poll_read_i128_varint, poll_read_u128_varint, InternalReadI128Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i128, poll_read_i128_varint_2_le, poll_read_u128_varint_2_le, InternalReadI128Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i128, poll_read_i128_varint_2_be, poll_read_u128_varint_2_be, InternalReadI128Varint2Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i128, poll_read_i128_varint_4_le, poll_read_u128_varint_4_le, InternalReadI128Varint4Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i128, poll_read_i128_varint_4_be, poll_read_u128_varint_4_be, InternalReadI128Varint4Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i128, poll_read_i128_varint_8_le, poll_read_u128_varint_8_le, InternalReadI128Varint8Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i128, poll_read_i128_varint_8_be, poll_read_u128_varint_8_be, InternalReadI128Varint8Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i128, poll_read_i128_varint_16_le, poll_read_u128_varint_16_le, InternalReadI128Varint16Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_poll!(i128, poll_read_i128_varint_16_be, poll_read_u128_varint_16_be, InternalReadI128Varint16Be);

        #[cfg(feature = "async_varint_size")]
        read_signed_size_poll!(poll_read_isize_varint, poll_read_usize_varint, InternalReadIsizeVarint);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_poll!(poll_read_isize_varint_2_le, poll_read_usize_varint_2_le, InternalReadIsizeVarint2Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_poll!(poll_read_isize_varint_2_be, poll_read_usize_varint_2_be, InternalReadIsizeVarint2Be);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_poll!(poll_read_isize_varint_4_le, poll_read_usize_varint_4_le, InternalReadIsizeVarint4Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_poll!(poll_read_isize_varint_4_be, poll_read_usize_varint_4_be, InternalReadIsizeVarint4Be);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_poll!(poll_read_isize_varint_8_le, poll_read_usize_varint_8_le, InternalReadIsizeVarint8Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_poll!(poll_read_isize_varint_8_be, poll_read_usize_varint_8_be, InternalReadIsizeVarint8Be);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_poll!(poll_read_isize_varint_16_le, poll_read_usize_varint_16_le, InternalReadIsizeVarint16Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_poll!(poll_read_isize_varint_16_be, poll_read_usize_varint_16_be, InternalReadIsizeVarint16Be);
    };
}
#[cfg(feature = "async_signed")]
macro_rules! define_read_signed_func {
    () => {
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i8_varint, ReadI8Varint, InternalReadI8Varint);

        read_signed_func!(read_i16_varint, ReadI16Varint, InternalReadI16Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i16_varint_2_le, ReadI16Varint2Le, InternalReadI16Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i16_varint_2_be, ReadI16Varint2Be, InternalReadI16Varint2Be);

        read_signed_func!(read_i32_varint, ReadI32Varint, InternalReadI32Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i32_varint_2_le, ReadI32Varint2Le, InternalReadI32Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i32_varint_2_be, ReadI32Varint2Be, InternalReadI32Varint2Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i32_varint_4_le, ReadI32Varint4Le, InternalReadI32Varint4Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i32_varint_4_be, ReadI32Varint4Be, InternalReadI32Varint4Be);

        read_signed_func!(read_i64_varint, ReadI64Varint, InternalReadI64Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i64_varint_2_le, ReadI64Varint2Le, InternalReadI64Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i64_varint_2_be, ReadI64Varint2Be, InternalReadI64Varint2Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i64_varint_4_le, ReadI64Varint4Le, InternalReadI64Varint4Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i64_varint_4_be, ReadI64Varint4Be, InternalReadI64Varint4Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i64_varint_8_le, ReadI64Varint8Le, InternalReadI64Varint8Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i64_varint_8_be, ReadI64Varint8Be, InternalReadI64Varint8Be);

        read_signed_func!(read_i128_varint, ReadI128Varint, InternalReadI128Varint);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i128_varint_2_le, ReadI128Varint2Le, InternalReadI128Varint2Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i128_varint_2_be, ReadI128Varint2Be, InternalReadI128Varint2Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i128_varint_4_le, ReadI128Varint4Le, InternalReadI128Varint4Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i128_varint_4_be, ReadI128Varint4Be, InternalReadI128Varint4Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i128_varint_8_le, ReadI128Varint8Le, InternalReadI128Varint8Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i128_varint_8_be, ReadI128Varint8Be, InternalReadI128Varint8Be);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i128_varint_16_le, ReadI128Varint16Le, InternalReadI128Varint16Le);
        #[cfg(feature = "async_long_signed")]
        read_signed_func!(read_i128_varint_16_be, ReadI128Varint16Be, InternalReadI128Varint16Be);

        #[cfg(feature = "async_varint_size")]
        read_signed_size_func!(read_isize_varint, ReadIsizeVarint, InternalReadIsizeVarint);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_func!(read_isize_varint_2_le, ReadIsizeVarint2Le, InternalReadIsizeVarint2Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_func!(read_isize_varint_2_be, ReadIsizeVarint2Be, InternalReadIsizeVarint2Be);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_func!(read_isize_varint_4_le, ReadIsizeVarint4Le, InternalReadIsizeVarint4Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_func!(read_isize_varint_4_be, ReadIsizeVarint4Be, InternalReadIsizeVarint4Be);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_func!(read_isize_varint_8_le, ReadIsizeVarint8Le, InternalReadIsizeVarint8Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_func!(read_isize_varint_8_be, ReadIsizeVarint8Be, InternalReadIsizeVarint8Be);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_func!(read_isize_varint_16_le, ReadIsizeVarint16Le, InternalReadIsizeVarint16Le);
        #[cfg(all(feature = "async_varint_size", feature = "async_long_signed"))]
        read_signed_size_func!(read_isize_varint_16_be, ReadIsizeVarint16Be, InternalReadIsizeVarint16Be);
    };
}
#[cfg(feature = "async_signed")]
define_read_signed_futures!();