rustis 0.19.3

Redis async driver for Rust
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

use crate::{
    Error, Result,
    resp::{RespBuf, RespFrameParser, RespResponse},
};
use bytes::BytesMut;
use tokio_util::codec::Decoder;

pub(crate) struct BufferDecoder;

impl Decoder for BufferDecoder {
    type Item = RespResponse;
    type Error = Error;

    fn decode(&mut self, src: &mut BytesMut) -> Result<Option<Self::Item>> {
        if src.is_empty() {
            return Ok(None);
        }

        match RespFrameParser::new(src.as_ref()).parse() {
            Ok((frame, frame_len)) => {
                let bytes = src.split_to(frame_len).freeze();
                Ok(Some(RespResponse::new(RespBuf::from(bytes), frame)))
            }
            Err(Error::EOF) => Ok(None),
            Err(e) => Err(e),
        }
    }
}