Is there a way to share a state/connection ?

[Roms1383]

Hello ! I've hesitated before coming ask this question, but after many unsuccessful attempts I finally could use a hint.

Most of the crate usage is very straightforward since similar concepts with tower, axum etc but I couldn't understand if there's a way to share a State (e.g. with some connection, so usually an Arc<State>).

I've tried different ways (especially fn_factory_with_config) but always end up getting:

error: cannot move out of `state`, a captured variable in an `Fn` closure
label: captured by this `Fn` closure

What did I miss here ?

[Roms1383]

Here's a sample of what I try to achieve, built from examples and people's feedback on other discussions (especially this one):

pub(crate) async fn launch(state: Arc<State>) -> Result<(), anyhow::Error> {
    let uri = "127.0.0.1:8883";
    let state = state.clone();
    let _ = ntex::server::Server::build()
        .bind("mqtt", uri, move |_| {
            let state = state.clone();
            MqttServer::new()
                .v3(
                    v3::MqttServer::new(handshake_v3).publish(fn_factory_with_config(
                        move |_: v3::Session<Session>| async move {
                            // let state = state.clone(); // 👈 as soon as uncommented, yields a compiler error
                            Ok::<_, crate::error::Error>(fn_service(move |publish: v3::Publish| {
                                // let state = state.clone().client;
                                // publish_v3(publish, client)
                                //                     ^^^^^^  where client is, e.g. influxdb2::Client
                                ok::<(), crate::error::Error>(())
                            }))
                        },
                    )),
                )
                .v5(v5::MqttServer::new(handshake_v5).publish(publish_v5))
        })?
        .workers(1)
        .run()
        .await;
    Ok(())
}

And here's what it yields:

Does not seem that everything has to implement Copy though,
since I remember @estin shared a code sample where mpsc::UnboundedSender which doesn't,
so I feel like I'm definitely missing something here.

Some help would be very much appreciated 😅

[Roms1383]

Well, so big rookie mistakes that costed me hours, here's how it finally compiles:

pub(crate) async fn launch(state: Arc<State>) -> Result<(), anyhow::Error> {
    let uri = "127.0.0.1:8883";
    let state = state.clone();
    let _ = ntex::server::Server::build()
        .bind("mqtt", uri, move |_| {
            let state = state.clone();
            MqttServer::new()
                .v3(
                    v3::MqttServer::new(handshake_v3).publish(fn_factory_with_config(
                        move |_: v3::Session<Session>| {
                            let state = state.clone();
                            ok::<_, crate::error::Error>(fn_service(move |publish: v3::Publish| {
                                let client = state.clone().client.clone();
                                publish_v3(publish, client)
                            }))
                        },
                    )),
                )
                .v5(v5::MqttServer::new(handshake_v5).publish(publish_v5))
        })?
        .workers(1)
        .run()
        .await;
    Ok(())
}

Pretty intense.