Method decode

src/storage/src/decode/avro.rs:34–48

(
        &mut self,
        bytes: &mut &[u8],
    )

    }

    pub async fn decode(
        &mut self,
        bytes: &mut &[u8],
    ) -> Result<Result<Option<Row>, DecodeErrorKind>, anyhow::Error> {
        let result = match self.decoder.decode(bytes).await? {
            Ok(row) => {
                self.events_success += 1;
                Ok(Some(row))
            }
            Err(err) => Err(DecodeErrorKind::Text(
                format!("avro deserialization error: {}", err.display_with_causes()).into(),
            )),
        };
        Ok(result)
    }
}