respite 0.4.0

An async reader for RESP streams
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

use crate::{RespError, RespValue};
use bytes::Bytes;

/// A primitive value that can be used as the key for a map or set.
#[derive(Clone, Debug, Eq, Hash, Ord, PartialEq, PartialOrd)]
pub enum RespPrimitive {
    Integer(i64),
    Nil,
    String(Bytes),
}

impl From<i64> for RespPrimitive {
    fn from(value: i64) -> Self {
        RespPrimitive::Integer(value)
    }
}

impl From<&'static str> for RespPrimitive {
    fn from(value: &'static str) -> Self {
        RespPrimitive::String(value.into())
    }
}

impl From<String> for RespPrimitive {
    fn from(value: String) -> Self {
        RespPrimitive::String(value.into())
    }
}

impl TryFrom<RespValue> for RespPrimitive {
    type Error = RespError;

    fn try_from(value: RespValue) -> Result<Self, Self::Error> {
        use RespPrimitive::*;
        Ok(match value {
            RespValue::Integer(value) => Integer(value),
            RespValue::Nil => RespPrimitive::Nil,
            RespValue::String(value) => String(value),
            _ => return Err(RespError::RespPrimitive),
        })
    }
}