Async Example with Websockets leads to InvalidUrl(Host)

[dtricks]

The basic async example given in the docs doesn't seem to work with websockets.

use rumqttc::{AsyncClient, MqttOptions, QoS};
use std::error::Error;
use std::time::Duration;
use tokio::{task, time};

#[tokio::main]
async fn main() {
    let mut mqttoptions = MqttOptions::new("rumqtt-async", "test.mosquitto.org", 8080);
    mqttoptions.set_keep_alive(Duration::from_secs(5));
    mqttoptions.set_transport(rumqttc::Transport::Ws);

    let (mut client, mut eventloop) = AsyncClient::new(mqttoptions, 10);
    client
        .subscribe("hello/rumqtt", QoS::AtMostOnce)
        .await
        .unwrap();

    task::spawn(async move {
        for i in 0..10 {
            client
                .publish("hello/rumqtt", QoS::AtLeastOnce, false, vec![i; i as usize])
                .await
                .unwrap();
            time::sleep(Duration::from_millis(100)).await;
        }
    });

    loop {
        let notification = eventloop.poll().await.unwrap();
        println!("Received = {:?}", notification);
    }
}

Output:

thread 'main' panicked at 'called `Result::unwrap()` on an `Err` value: InvalidUrl(Host)', src/main.rs:29:51
note: run with `RUST_BACKTRACE=1` environment variable to display a backtrace

test.mosquitto.org provides port
8080 : MQTT over WebSockets, unencrypted, unauthenticated

Is there something i am missing?

[dtricks]

Found the correct usage here:

https://github.com/bytebeamio/rumqtt/blob/main/rumqttc/examples/websocket.rs

My mistake was to trust the port parameter, this is the correct way to do it:

    // port parameter is ignored when scheme is websocket
    let mut mqttoptions = MqttOptions::new(
        "clientId-aSziq39Bp3",
        "ws://broker.mqttdashboard.com:8000/mqtt",
        8000,
    );
    mqttoptions.set_transport(Transport::Ws);
    mqttoptions.set_keep_alive(Duration::from_secs(60));