fn make_message_frame(channel_name: String, msg: Bytes) -> Frame {
    let mut response = Frame::array();
    response.push_bulk(Bytes::from_static(b"message"));
    response.push_bulk(Bytes::from(channel_name));
    response.push_bulk(msg);
    response
}
/// Creates a message informing the client about a new message on a channel that
/// the client subscribes to.
Creates a message informing the client about a new message on a channel that
the client subscribes to.
Creates a message informing the client about a new message on a channel that the client subscribes to .
fn make_message_frame(channel_name: String, msg: Bytes) -> Frame {
    let mut response = Frame::array();
    response.push_bulk(Bytes::from_static(b"message"));
    response.push_bulk(Bytes::from(channel_name));
    response.push_bulk(msg);
    response
}
fn make_message_frame ( channel_name : String , msg : Bytes ) -> Frame { let mut response = Frame :: array ( ) ; response . push_bulk ( Bytes :: from_static ( b" " ) ) ; response . push_bulk ( Bytes :: from ( channel_name ) ) ; response . push_bulk ( msg ) ; response }
Creates a message informing the client about a new message on a channel that
the client subscribes to.
Creates a message informing the client about a new message on a channel that the client subscribes to .
channel_name
String
msg
Bytes