Method decode

src/protocol/codec.rs:36–48

(&mut self, src: &mut BytesMut)

    type Error = io::Error;
    
    fn decode(&mut self, src: &mut BytesMut) -> Result<Option<Self::Item>, Self::Error> {
        match self.state {
            CodecState::WaitingForStartup => {
                if let Some(msg) = decode_startup_message(src)? {
                    self.state = CodecState::Normal;
                    Ok(Some(msg))
                } else {
                    Ok(None)
                }
            }
            CodecState::Normal => decode_normal_message(src),
        }
    }
}

impl Encoder<BackendMessage> for PostgresCodec {