netherite 0.1.3

A tokio implementation of the Minecraft Protocol with derive macros
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

use bytes::Buf;
use serde::de::SeqAccess;
use std::marker::PhantomData;

use super::VarIntError;

pub trait ConsumeByte {
    fn consume_byte(&mut self) -> Result<u8, VarIntError>;
}

impl<B: Buf> ConsumeByte for B {
    // type Error = VarIntError;
    fn consume_byte(&mut self) -> Result<u8, VarIntError> {
        self.has_remaining()
            .then(|| self.get_u8())
            .ok_or(VarIntError::Eof)
    }
}

pub struct SeqAccessAdapter<'de, S>(S, PhantomData<&'de ()>);

impl<S> SeqAccessAdapter<'_, S> {
    pub fn new(access: S) -> Self {
        Self(access, PhantomData::default())
    }
}

impl<'de, S: SeqAccess<'de>> ConsumeByte for SeqAccessAdapter<'de, S> {
    fn consume_byte(&mut self) -> Result<u8, VarIntError> {
        match self.0.next_element() {
            Ok(Some(v)) => Ok(v),
            _ => Err(VarIntError::Eof),
        }
    }
}