rabbitmq_stream_protocol/commands/
delete.rs

1use std::io::Write;
2
3use crate::{
4    codec::{Decoder, Encoder},
5    error::{DecodeError, EncodeError},
6    protocol::commands::COMMAND_DELETE_STREAM,
7};
8
9use super::Command;
10
11#[cfg_attr(test, derive(fake::Dummy))]
12#[derive(PartialEq, Eq, Debug)]
13pub struct Delete {
14    correlation_id: u32,
15    stream: String,
16}
17
18impl Delete {
19    pub fn new(correlation_id: u32, stream: String) -> Self {
20        Self {
21            correlation_id,
22            stream,
23        }
24    }
25}
26
27impl Encoder for Delete {
28    fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError> {
29        self.correlation_id.encode(writer)?;
30        self.stream.as_str().encode(writer)?;
31        Ok(())
32    }
33
34    fn encoded_size(&self) -> u32 {
35        self.correlation_id.encoded_size() + self.stream.as_str().encoded_size()
36    }
37}
38
39impl Command for Delete {
40    fn key(&self) -> u16 {
41        COMMAND_DELETE_STREAM
42    }
43}
44impl Decoder for Delete {
45    fn decode(input: &[u8]) -> Result<(&[u8], Self), DecodeError> {
46        let (input, correlation_id) = u32::decode(input)?;
47        let (input, stream) = Option::decode(input)?;
48
49        Ok((
50            input,
51            Delete {
52                correlation_id,
53                stream: stream.unwrap(),
54            },
55        ))
56    }
57}
58
59#[cfg(test)]
60mod tests {
61    use super::Delete;
62    use crate::commands::tests::command_encode_decode_test;
63
64    #[test]
65    fn delete_stream_request_test() {
66        command_encode_decode_test::<Delete>()
67    }
68}
rabbitmq_stream_protocol/commands/delete.rs

rabbitmq_stream_protocol/commands/
delete.rs
