diff --git a/src/codec.rs b/src/codec.rs index 723dc0a..91d65c1 100644 --- a/src/codec.rs +++ b/src/codec.rs @@ -8,8 +8,8 @@ use crate::{ command::{Command, ParamBuffer, Params, Response}, }; -const RETURN_CODE: u8 = b'\r'; -const PARAM_DELIMITER: u8 = b','; +pub(crate) const RETURN_CODE: u8 = b'\r'; +pub(crate) const PARAM_DELIMITER: u8 = b','; #[derive(Clone, Debug)] pub struct Codec { @@ -38,7 +38,7 @@ where dst.extend_from_slice(Cmd::TEXT); params.serialize_to(ParamBuffer::new(dst)); - dst.put_u8(b'\r'); + dst.put_u8(RETURN_CODE); Ok(()) } diff --git a/src/command/mod.rs b/src/command/mod.rs index d3866b7..900a581 100644 --- a/src/command/mod.rs +++ b/src/command/mod.rs @@ -10,6 +10,8 @@ pub(crate) use macros::{command, range_param, range_response}; pub(crate) use no_params::NoParams; pub use ok_response::{OkResponse, OkResponseError}; +use crate::codec::PARAM_DELIMITER; + pub trait Command { const TEXT: &'static [u8]; type Params: Params; @@ -40,7 +42,7 @@ impl<'a> ParamBuffer<'a> { } fn serialize_param(&mut self, bytes: &[u8]) { - self.0.put_u8(b','); + self.0.put_u8(PARAM_DELIMITER); self.0.extend_from_slice(bytes); } }