(&mut self, buf: &mut BytesMut)
| 237 | type Error = io::Error; |
| 238 | |
| 239 | fn decode(&mut self, buf: &mut BytesMut) -> Result<Option<Self::Item>, Self::Error> { |
| 240 | match &self.d_state { |
| 241 | DecodeState::Cmd => self.decode_cmd(buf), |
| 242 | DecodeState::Set { .. } => self.process_set(buf), |
| 243 | } |
| 244 | } |
| 245 | } |
| 246 | |
| 247 | impl Encoder<RedisServerMsg<'_>> for RedisCodec { |
nothing calls this directly
no test coverage detected