Allow nolocal in rumqttc

[danielboros1990]

Hi guys

how can I allow the nolocal mode in rumqttc? I tried to use Filter struct but AsyncClient has no method which can accept it.

let mut current_topics = vec![];
    let (client, mut event_loop) = AsyncClient::new(mqttoptions, 10);

    task::spawn({
        let client = client.clone();

        async move {
            while let Some(topics) = &rx_topics.recv().await {
                tracing::info!("Received topics: {:?}", topics);
                let _ = futures::future::join_all(unsubscribe_from_old_topics(&client, &current_topics, topics).await)
                    .await;
                let _ = futures::future::join_all(subscribe_to_new_topics(&client, topics).await).await;

                current_topics = topics.clone();
            }
            time::sleep(Duration::from_secs(3)).await;
        }
    });

async fn subscribe_to_new_topics(client: &AsyncClient, topics: &[String]) -> Vec<tokio::task::JoinHandle<()>> {
    topics
        .iter()
        .map(|t| {
            let client = client.clone();
            let t = t.to_string();

            async move {
                client.subscribe(t, QoS::ExactlyOnce).await.unwrap();
            }
        })
        .map(tokio::spawn)
        .collect::<Vec<_>>()
}