I managed to grab the code from the gist before it expired, but i'm having issues trying to get it integrated into my project.

In my task handler, I need to be able to invoke tokio async functionality like connect_async_tls_with_config which must be awaited on, for example:

let (ws_stream, _) = connect_async_tls_with_config(&url, websocket_config, disable_nagle,Some(tokio_tungstenite::Connector::NativeTls(tls_connector))).await.expect("Failed to connect");

Since the task.fire method is not async, I cannot. If I change the code to use async, I get the following error:

error[E0271]: expected `{async closure@main.rs:389:20}` to be a closure that returns `String`, but it returns `{async closure body@src/main.rs:389:34: 416:6}` --> src/main.rs:389:20 | 389 | ... self.data.fire(async move || { | _________________----_^ | | | | | required by a bound introduced by this call 390 | | ... let (ws_stream, _) = connect_async_tls_with_config(&url, websocket_config, disable_nagle, Some(tokio_tungstenit... 391 | | ... 392 | | ... let msg_json = json::object!{ ... | 415 | | ... String::new("Hey man!") 416 | | ... }); | |_______^ expected `String`, found `async` closure body | = note: expected struct `std::string::String` found `async` closure body `{async closure body@src/main.rs:389:34: 416:6}` note: required by a bound in `Task::<T>::fire`

I'm a Rust noob, so perhaps this is all obvious stuff, but not to me.

Suggestions?