sage_mqtt 0.5.0

Manipulate MQTT 5.0 data types
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use std::io::prelude::*;
use std::net::TcpStream;

use sage_mqtt::Packet;

#[tokio::main(flavor = "current_thread")]
async fn main() -> std::io::Result<()> {
    let mut stream = TcpStream::connect("127.0.0.1:7878")?;

    let mut encoded = Vec::new();
    Packet::Connect(Default::default())
        .encode(&mut encoded)
        .await
        .unwrap();

    stream.write_all(&encoded)?;
    Ok(())
} // the stream is closed here