Method new

redis-server/src/codec.rs:56–61

(cache: Arc<CacheT>)

impl RedisCodec {
    pub fn new(cache: Arc<CacheT>) -> Self {
        RedisCodec {
            cache,
            d_state: DecodeState::Cmd,
        }
    }

    fn decode_cmd(&mut self, buf: &mut BytesMut) -> Result<Option<RedisClientMsg>, io::Error> {
        trace!("cap: {}: len: {}", buf.capacity(), buf.len());