Function simple_pub_sub::stream::read_message

source · 
pub async fn read_message(s: &mut TcpStream) -> Result<Msg, Error>
Expand description

reads a data from a TcpStream and returns a Msg.