message_protocol

Function connect_to_tcp

Source 
pub fn connect_to_tcp<T: ToSocketAddrs>(
    connect_to_address: T,
) -> Result<(Receiver<Message>, WriteFunction), Error>
Expand description

Connect to TCP on a given address.

Example:

let (rx, mut write) = message_protocol::connect_to_tcp("127.0.0.1:45932")?;
write.call(b"hi server").unwrap();
while let Ok(msg) = rx.recv() {
    println!("client recieved");
    match msg {
        message_protocol::Message::Open => println!("open"),
        message_protocol::Message::Bytes(b) => println!("bytes {:?}", b),
        message_protocol::Message::Close => println!("close"),
    };
 }