fn decode(&self, data: &Bytes) -> Result<Option<(Self::FrameType, usize)>, RedisProtocolError> {
        match resp3::decode::streaming::decode(data) {
            Ok(option) => match option {
                None => Ok(None),
                Some(decoded) => {
                    let (frame, size) = decoded;
                    match frame {
                        DecodedFrame::Streaming(_) => Ok(None),
                        DecodedFrame::Complete(complete_frame) => Ok(Some((complete_frame, size))),
                    }
                }
            },
            Err(error) => Err(error),
        }
    }
/// Currently just decodes complete frames
/// In case of streaming frame None is returned. In Redis <= 6 there is currently no command
/// returning a stream frame.
Currently just decodes complete frames
In case of streaming frame None is returned. In Redis <= 6 there is currently no command
returning a stream frame.
Currently just decodes complete frames In case of streaming frame None is returned . In Redis < = 6 there is currently no command returning a stream frame .
fn decode(&self, data: &Bytes) -> Result<Option<(Self::FrameType, usize)>, RedisProtocolError> {
        match resp3::decode::streaming::decode(data) {
            Ok(option) => match option {
                None => Ok(None),
                Some(decoded) => {
                    let (frame, size) = decoded;
                    match frame {
                        DecodedFrame::Streaming(_) => Ok(None),
                        DecodedFrame::Complete(complete_frame) => Ok(Some((complete_frame, size))),
                    }
                }
            },
            Err(error) => Err(error),
        }
    }
fn decode ( & self , data : & Bytes ) -> Result < Option < ( Self :: FrameType , usize ) > , RedisProtocolError > { match resp3 :: decode :: streaming :: decode ( data ) { Ok ( option ) => match option { None => Ok ( None ) , Some ( decoded ) => { let ( frame , size ) = decoded ; match frame { DecodedFrame :: Streaming ( _ ) => Ok ( None ) , DecodedFrame :: Complete ( complete_frame ) => Ok ( Some ( ( complete_frame , size ) ) ) , } } } , Err ( error ) => Err ( error ) , } }
Currently just decodes complete frames
In case of streaming frame None is returned.
Currently just decodes complete frames In case of streaming frame None is returned .
&self
data
&Bytes
&self
data
&Bytes