rabbitmq_stream_protocol/commands/
heart_beat.rs

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

rabbitmq_stream_protocol/commands/
heart_beat.rs
