in src/codec/redis.rs [43:64]
fn command(buf: &mut Session, mode: &Mode, command: &str, args: Vec<Vec<u8>>) {
match mode {
Mode::Inline => {
let _ = buf.write_all(command.to_string().as_bytes());
for arg in args {
let _ = buf.write_all(b" ");
let _ = buf.write_all(&arg);
}
let _ = buf.write_all(b"\r\n");
}
Mode::Resp => {
let _ = buf.write_all(
format!("*{}\r\n${}\r\n{}", 1 + args.len(), command.len(), command).as_bytes(),
);
for arg in args {
let _ = buf.write_all(format!("\r\n${}\r\n", arg.len()).as_bytes());
let _ = buf.write_all(&arg);
}
let _ = buf.write_all(b"\r\n");
}
}
}