variable_len_reader/asynchronous/
read_signed_varint.rs

1macro_rules! read_signed_varint_future {
2    ($primitive: ty, $future: ident, $inner_future: ident) => {
3        read_signed_varint_future!(f cfg(feature = "async_signed_varint"), $primitive, $future, $inner_future);
4    };
5    (f $feature: meta, $primitive: ty, $future: ident, $inner_future: ident) => {
6        read_wrap_future!(f $feature, $future, $inner_future);
7        #[$feature]
8        impl<'a, R: AsyncVariableReader + Unpin + ?Sized> Future for $future<'a, R> {
9            type Output = ::core::result::Result<$primitive, R::Error>;
10
11            fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
12                use $crate::util::zigzag::Zigzag;
13                self.project().inner.poll(cx).map_ok(|v| v.zigzag())
14            }
15        }
16    };
17}
18macro_rules! read_signed_varint_func {
19    ($future: ident, $func: ident, $inner_func: ident) => {
20        read_signed_varint_func!(f cfg(feature = "async_signed_varint"), $future, $func, $inner_func);
21    };
22    (f $feature: meta, $future: ident, $func: ident, $inner_func: ident) => {
23        read_wrap_func!(f $feature, $future, $func, $inner_func);
24    };
25}
26
27macro_rules! define_read_signed_varint_future {
28    () => {
29        read_signed_varint_future!(i16, ReadI16Varint, ReadU16Varint);
30        read_signed_varint_future!(i32, ReadI32Varint, ReadU32Varint);
31        read_signed_varint_future!(i64, ReadI64Varint, ReadU64Varint);
32        read_signed_varint_future!(i128, ReadI128Varint, ReadU128Varint);
33    };
34}
35macro_rules! define_read_signed_varint_func {
36    () => {
37        read_signed_varint_func!(ReadI16Varint, read_i16_varint, read_u16_varint);
38        read_signed_varint_func!(ReadI32Varint, read_i32_varint, read_u32_varint);
39        read_signed_varint_func!(ReadI64Varint, read_i64_varint, read_u64_varint);
40        read_signed_varint_func!(ReadI128Varint, read_i128_varint, read_u128_varint);
41    };
42}
43
44define_read_signed_varint_future!();
45
46#[cfg(all(feature = "async_signed_varint", not(feature = "async_varint")))]
47compile_error!("developer error: please check Cargo.toml");
variable_len_reader/asynchronous/read_signed_varint.rs

variable_len_reader/asynchronous/
read_signed_varint.rs
