[INFO] fetching crate zenoh-plugin-mqtt 0.10.0-rc... [INFO] checking zenoh-plugin-mqtt-0.10.0-rc against master#3f28fe133475ec5faf3413b556bf3cfb0d51336c for pr-112365-2 [INFO] extracting crate zenoh-plugin-mqtt 0.10.0-rc into /workspace/builds/worker-2-tc1/source [INFO] validating manifest of crates.io crate zenoh-plugin-mqtt 0.10.0-rc on toolchain 3f28fe133475ec5faf3413b556bf3cfb0d51336c [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+3f28fe133475ec5faf3413b556bf3cfb0d51336c" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] started tweaking crates.io crate zenoh-plugin-mqtt 0.10.0-rc [INFO] finished tweaking crates.io crate zenoh-plugin-mqtt 0.10.0-rc [INFO] tweaked toml for crates.io crate zenoh-plugin-mqtt 0.10.0-rc written to /workspace/builds/worker-2-tc1/source/Cargo.toml [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+3f28fe133475ec5faf3413b556bf3cfb0d51336c" "generate-lockfile" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+3f28fe133475ec5faf3413b556bf3cfb0d51336c" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded keyed-set v0.4.5 [INFO] [stderr] Downloaded uhlc v0.6.3 [INFO] [stderr] Downloaded zenoh-plugin-trait v0.10.0-rc [INFO] [stderr] Downloaded zenoh-link-udp v0.10.0-rc [INFO] [stderr] Downloaded zenoh-collections v0.10.0-rc [INFO] [stderr] Downloaded zenoh-link-tcp v0.10.0-rc [INFO] [stderr] Downloaded zenoh v0.10.0-rc [INFO] [stderr] Downloaded zenoh-crypto v0.10.0-rc [INFO] [stderr] Downloaded zenoh-protocol v0.10.0-rc [INFO] [stderr] Downloaded zenoh-util v0.10.0-rc [INFO] [stderr] Downloaded zenoh-link-commons v0.10.0-rc [INFO] [stderr] Downloaded zenoh-transport v0.10.0-rc [INFO] [stderr] Downloaded zenoh-codec v0.10.0-rc [INFO] [stderr] Downloaded zenoh-config v0.10.0-rc [INFO] [stderr] Downloaded zenoh-link-ws v0.10.0-rc [INFO] [stderr] Downloaded ntex-async-std v0.1.1 [INFO] [stderr] Downloaded ntex-connect v0.1.1 [INFO] [stderr] Downloaded ntex-h2 v0.1.6 [INFO] [stderr] Downloaded ntex-io v0.1.11 [INFO] [stderr] Downloaded ntex-tls v0.1.7 [INFO] [stderr] Downloaded ntex v0.5.31 [INFO] [stderr] Downloaded ntex-service v0.3.3 [INFO] [stderr] Downloaded ntex-util v0.1.19 [INFO] [stderr] Downloaded ntex-mqtt v0.9.2 [INFO] [stderr] Downloaded zenoh-macros v0.10.0-rc [INFO] [stderr] Downloaded zenoh-link-unixsock_stream v0.10.0-rc [INFO] [stderr] Downloaded token-cell v1.5.0 [INFO] [stderr] Downloaded zenoh-result v0.10.0-rc [INFO] [stderr] Downloaded zenoh-sync v0.10.0-rc [INFO] [stderr] Downloaded zenoh-buffers v0.10.0-rc [INFO] [stderr] Downloaded async-rustls v0.4.2 [INFO] [stderr] Downloaded zenoh-link-tls v0.10.0-rc [INFO] [stderr] Downloaded zenoh-link v0.10.0-rc [INFO] [stderr] Downloaded zenoh-core v0.10.0-rc [INFO] [stderr] Downloaded zenoh-link-quic v0.10.0-rc [INFO] [stderr] Downloaded zenoh-keyexpr v0.10.0-rc [INFO] [stderr] Downloaded zenoh-ext v0.10.0-rc [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+3f28fe133475ec5faf3413b556bf3cfb0d51336c" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] a3480fe46f4b1a234c7652a7b66841087239231f473d411569af81b24a46b5ac [INFO] running `Command { std: "docker" "start" "-a" "a3480fe46f4b1a234c7652a7b66841087239231f473d411569af81b24a46b5ac", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "a3480fe46f4b1a234c7652a7b66841087239231f473d411569af81b24a46b5ac", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "a3480fe46f4b1a234c7652a7b66841087239231f473d411569af81b24a46b5ac", kill_on_drop: false }` [INFO] [stdout] a3480fe46f4b1a234c7652a7b66841087239231f473d411569af81b24a46b5ac [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+3f28fe133475ec5faf3413b556bf3cfb0d51336c" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 4b9f7bbdd948657d4a36fa2962182b419f6b65067eee8442efba7d3c3f9a9a07 [INFO] running `Command { std: "docker" "start" "-a" "4b9f7bbdd948657d4a36fa2962182b419f6b65067eee8442efba7d3c3f9a9a07", kill_on_drop: false }` [INFO] [stderr] Checking log v0.4.20 [INFO] [stderr] Compiling serde v1.0.195 [INFO] [stderr] Checking getrandom v0.2.11 [INFO] [stderr] Checking spin v0.9.8 [INFO] [stderr] Compiling rustix v0.38.28 [INFO] [stderr] Compiling ahash v0.8.7 [INFO] [stderr] Checking futures-sink v0.3.30 [INFO] [stderr] Checking tokio v1.35.1 [INFO] [stderr] Checking rustix v0.37.27 [INFO] [stderr] Checking rand_core v0.6.4 [INFO] [stderr] Compiling cc v1.0.83 [INFO] [stderr] Checking tracing v0.1.40 [INFO] [stderr] Checking polling v2.8.0 [INFO] [stderr] Checking socket2 v0.4.10 [INFO] [stderr] Checking blocking v1.5.1 [INFO] [stderr] Checking event-listener v3.1.0 [INFO] [stderr] Compiling anyhow v1.0.79 [INFO] [stderr] Checking rand_chacha v0.3.1 [INFO] [stderr] Checking kv-log-macro v1.0.7 [INFO] [stderr] Compiling async-attributes v1.1.2 [INFO] [stderr] Checking rand v0.8.5 [INFO] [stderr] Compiling serde_derive_internals v0.26.0 [INFO] [stderr] Compiling schemars v0.8.16 [INFO] [stderr] Compiling ring v0.17.7 [INFO] [stderr] Checking lazy_static v1.4.0 [INFO] [stderr] Checking allocator-api2 v0.2.16 [INFO] [stderr] Checking const-oid v0.9.6 [INFO] [stderr] Checking zenoh-result v0.10.0-rc [INFO] [stderr] Checking nanorand v0.7.0 [INFO] [stderr] Checking async-io v1.13.0 [INFO] [stderr] Checking hashbrown v0.14.3 [INFO] [stderr] Checking hashbrown v0.13.2 [INFO] [stderr] Compiling aho-corasick v1.1.2 [INFO] [stderr] Compiling schemars_derive v0.8.16 [INFO] [stderr] Checking futures-channel v0.3.30 [INFO] [stderr] Compiling regex-syntax v0.8.2 [INFO] [stderr] Checking serde_json v1.0.111 [INFO] [stderr] Checking dyn-clone v1.0.16 [INFO] [stderr] Checking no-std-net v0.6.0 [INFO] [stderr] Checking zenoh-collections v0.10.0-rc [INFO] [stderr] Checking futures-util v0.3.30 [INFO] [stderr] Checking zenoh-buffers v0.10.0-rc [INFO] [stderr] Checking pnet_base v0.34.0 [INFO] [stderr] Checking keyed-set v0.4.5 [INFO] [stderr] Checking token-cell v1.5.0 [INFO] [stderr] Checking digest v0.10.7 [INFO] [stderr] Checking uhlc v0.6.3 [INFO] [stderr] Compiling ring v0.16.20 [INFO] [stderr] Checking uuid v1.6.1 [INFO] [stderr] Checking polling v3.3.1 [INFO] [stderr] Checking pnet_macros_support v0.34.0 [INFO] [stderr] Checking flume v0.11.0 [INFO] [stderr] Checking async-io v2.2.2 [INFO] [stderr] Checking pnet_sys v0.34.0 [INFO] [stderr] Compiling indexmap v1.9.3 [INFO] [stderr] Checking ipnetwork v0.20.0 [INFO] [stderr] Compiling regex-automata v0.4.3 [INFO] [stderr] Checking os_str_bytes v6.6.1 [INFO] [stderr] Checking async-signal v0.2.5 [INFO] [stderr] Checking async-process v1.8.1 [INFO] [stderr] Checking async-global-executor v2.4.1 [INFO] [stderr] Compiling pnet v0.34.0 [INFO] [stderr] Checking zenoh-keyexpr v0.10.0-rc [INFO] [stderr] Checking async-std v1.12.0 [INFO] [stderr] Checking sct v0.7.1 [INFO] [stderr] Checking futures-executor v0.3.30 [INFO] [stderr] Checking clap_lex v0.2.4 [INFO] [stderr] Checking futures v0.3.30 [INFO] [stderr] Checking pnet_datalink v0.34.0 [INFO] [stderr] Checking atty v0.2.14 [INFO] [stderr] Checking textwrap v0.16.0 [INFO] [stderr] Checking shellexpand v3.1.0 [INFO] [stderr] Checking libloading v0.8.1 [INFO] [stderr] Checking clap v3.2.25 [INFO] [stderr] Checking home v0.5.9 [INFO] [stderr] Compiling unzip-n v0.1.2 [INFO] [stderr] Compiling libm v0.2.8 [INFO] [stderr] Compiling rustls v0.21.10 [INFO] [stderr] Checking zenoh-protocol v0.10.0-rc [INFO] [stderr] Compiling semver v1.0.21 [INFO] [stderr] Checking rustls-webpki v0.101.7 [INFO] [stderr] Checking ntex-bytes v0.1.21 [INFO] [stderr] Compiling num-traits v0.2.17 [INFO] [stderr] Checking indexmap v2.1.0 [INFO] [stderr] Checking zenoh-codec v0.10.0-rc [INFO] [stderr] Compiling regex v1.10.2 [INFO] [stderr] Checking zenoh-core v0.10.0-rc [INFO] [stderr] Checking zenoh-sync v0.10.0-rc [INFO] [stderr] Checking zeroize v1.7.0 [INFO] [stderr] Checking zenoh-link-commons v0.10.0-rc [INFO] [stderr] Compiling zerocopy v0.7.32 [INFO] [stderr] Checking oneshot v0.1.6 [INFO] [stderr] Checking base64ct v1.6.0 [INFO] [stderr] Checking json5 v0.4.1 [INFO] [stderr] Checking ntex-rt v0.4.11 [INFO] [stderr] Compiling rustc_version v0.4.0 [INFO] [stderr] Checking pem-rfc7468 v0.7.0 [INFO] [stderr] Compiling validated_struct_macros v2.1.0 [INFO] [stderr] Compiling num-integer v0.1.45 [INFO] [stderr] Checking ntex-service v0.3.3 [INFO] [stderr] Checking unsafe-libyaml v0.2.10 [INFO] [stderr] Checking der v0.7.8 [INFO] [stderr] Checking ntex-codec v0.6.2 [INFO] [stderr] Checking ntex-util v0.1.19 [INFO] [stderr] Checking sha1 v0.10.6 [INFO] [stderr] Checking webpki v0.22.4 [INFO] [stderr] Compiling num-iter v0.1.43 [INFO] [stderr] Checking utf-8 v0.7.6 [INFO] [stderr] Checking serde_yaml v0.9.30 [INFO] [stderr] Checking data-encoding v2.5.0 [INFO] [stderr] Compiling rustls v0.20.9 [INFO] [stderr] Compiling pnet_macros v0.34.0 [INFO] [stderr] Checking spki v0.7.3 [INFO] [stderr] Checking validated_struct v2.1.0 [INFO] [stderr] Checking tungstenite v0.20.1 [INFO] [stderr] Checking quinn-proto v0.10.6 [INFO] [stderr] Checking ntex-io v0.1.11 [INFO] [stderr] Checking async-rustls v0.4.2 [INFO] [stderr] Checking inout v0.1.3 [INFO] [stderr] Checking quinn-udp v0.4.1 [INFO] [stderr] Checking futures-micro v0.5.0 [INFO] [stderr] Compiling num-bigint-dig v0.8.4 [INFO] [stderr] Checking async-oneshot v0.5.9 [INFO] [stderr] Checking tokio-tungstenite v0.20.1 [INFO] [stderr] Checking cipher v0.4.4 [INFO] [stderr] Checking pkcs8 v0.10.2 [INFO] [stderr] Checking nix v0.27.1 [INFO] [stderr] Compiling zenoh-macros v0.10.0-rc [INFO] [stderr] Checking twox-hash v1.6.3 [INFO] [stderr] Checking sha3 v0.10.8 [INFO] [stderr] Checking pnet_packet v0.34.0 [INFO] [stderr] Checking pkcs1 v0.7.5 [INFO] [stderr] Checking aes v0.8.3 [INFO] [stderr] Checking ntex-async-std v0.1.1 [INFO] [stderr] Checking zenoh-link-unixsock_stream v0.10.0-rc [INFO] [stderr] Checking webpki-roots v0.22.6 [INFO] [stderr] Checking ntex-http v0.1.11 [INFO] [stderr] Checking hmac v0.12.1 [INFO] [stderr] Checking signature v2.2.0 [INFO] [stderr] Checking array-init v2.1.0 [INFO] [stderr] Checking cache-padded v1.3.0 [INFO] [stderr] Checking zenoh-crypto v0.10.0-rc [INFO] [stderr] Checking lz4_flex v0.11.1 [INFO] [stderr] Checking rsa v0.9.6 [INFO] [stderr] Checking ringbuffer-spsc v0.1.9 [INFO] [stderr] Compiling zenoh v0.10.0-rc [INFO] [stderr] Checking quinn v0.10.2 [INFO] [stderr] Checking is-terminal v0.4.10 [INFO] [stderr] Compiling git-version-macro v0.3.9 [INFO] [stderr] Checking fixedbitset v0.4.2 [INFO] [stderr] Checking env_logger v0.10.1 [INFO] [stderr] Checking ntex-tls v0.1.7 [INFO] [stderr] Checking petgraph v0.6.4 [INFO] [stderr] Checking ntex-router v0.5.2 [INFO] [stderr] Checking ordered-float v3.9.2 [INFO] [stderr] Checking ntex-connect v0.1.1 [INFO] [stderr] Checking serde_urlencoded v0.7.1 [INFO] [stderr] Checking ntex-h2 v0.1.6 [INFO] [stderr] Checking sha-1 v0.10.1 [INFO] [stderr] Checking stop-token v0.7.0 [INFO] [stderr] Compiling ntex-macros v0.1.3 [INFO] [stderr] Compiling derive_more v0.99.17 [INFO] [stderr] Checking git-version v0.3.9 [INFO] [stderr] Compiling zenoh-plugin-mqtt v0.10.0-rc (/opt/rustwide/workdir) [INFO] [stderr] Checking bincode v1.3.3 [INFO] [stderr] Checking flume v0.10.14 [INFO] [stderr] Checking ntex v0.5.31 [INFO] [stderr] Checking pnet_transport v0.34.0 [INFO] [stderr] Checking zenoh-util v0.10.0-rc [INFO] [stderr] Checking zenoh-config v0.10.0-rc [INFO] [stderr] Checking zenoh-link-ws v0.10.0-rc [INFO] [stderr] Checking zenoh-link-tcp v0.10.0-rc [INFO] [stderr] Checking zenoh-link-udp v0.10.0-rc [INFO] [stderr] Checking zenoh-plugin-trait v0.10.0-rc [INFO] [stderr] Checking zenoh-link-tls v0.10.0-rc [INFO] [stderr] Checking zenoh-link-quic v0.10.0-rc [INFO] [stderr] Checking zenoh-link v0.10.0-rc [INFO] [stderr] Checking zenoh-transport v0.10.0-rc [INFO] [stderr] Checking ntex-mqtt v0.9.2 [INFO] [stderr] Checking zenoh-ext v0.10.0-rc [INFO] [stderr] Finished dev [unoptimized + debuginfo] target(s) in 19.43s [INFO] running `Command { std: "docker" "inspect" "4b9f7bbdd948657d4a36fa2962182b419f6b65067eee8442efba7d3c3f9a9a07", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "4b9f7bbdd948657d4a36fa2962182b419f6b65067eee8442efba7d3c3f9a9a07", kill_on_drop: false }` [INFO] [stdout] 4b9f7bbdd948657d4a36fa2962182b419f6b65067eee8442efba7d3c3f9a9a07 [INFO] checking zenoh-plugin-mqtt-0.10.0-rc against try#2eb702bf20a12c67e5629a5c82890c910c267bd9 for pr-112365-2 [INFO] extracting crate zenoh-plugin-mqtt 0.10.0-rc into /workspace/builds/worker-2-tc2/source [INFO] validating manifest of crates.io crate zenoh-plugin-mqtt 0.10.0-rc on toolchain 2eb702bf20a12c67e5629a5c82890c910c267bd9 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+2eb702bf20a12c67e5629a5c82890c910c267bd9" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] started tweaking crates.io crate zenoh-plugin-mqtt 0.10.0-rc [INFO] finished tweaking crates.io crate zenoh-plugin-mqtt 0.10.0-rc [INFO] tweaked toml for crates.io crate zenoh-plugin-mqtt 0.10.0-rc written to /workspace/builds/worker-2-tc2/source/Cargo.toml [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+2eb702bf20a12c67e5629a5c82890c910c267bd9" "generate-lockfile" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+2eb702bf20a12c67e5629a5c82890c910c267bd9" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+2eb702bf20a12c67e5629a5c82890c910c267bd9" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] bccde7dd859bbd6dea676a7f09119edfe086be239a06979c6dad0ab9a277b719 [INFO] running `Command { std: "docker" "start" "-a" "bccde7dd859bbd6dea676a7f09119edfe086be239a06979c6dad0ab9a277b719", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "bccde7dd859bbd6dea676a7f09119edfe086be239a06979c6dad0ab9a277b719", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "bccde7dd859bbd6dea676a7f09119edfe086be239a06979c6dad0ab9a277b719", kill_on_drop: false }` [INFO] [stdout] bccde7dd859bbd6dea676a7f09119edfe086be239a06979c6dad0ab9a277b719 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+2eb702bf20a12c67e5629a5c82890c910c267bd9" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 3add12c5707bbc83ed6e7eaf37e917d6b9355781308a3aed54b347775d89f782 [INFO] running `Command { std: "docker" "start" "-a" "3add12c5707bbc83ed6e7eaf37e917d6b9355781308a3aed54b347775d89f782", kill_on_drop: false }` [INFO] [stderr] Checking log v0.4.20 [INFO] [stderr] Compiling serde v1.0.195 [INFO] [stderr] Checking getrandom v0.2.11 [INFO] [stderr] Checking spin v0.9.8 [INFO] [stderr] Compiling rustix v0.38.28 [INFO] [stderr] Compiling ahash v0.8.7 [INFO] [stderr] Checking futures-sink v0.3.30 [INFO] [stderr] Checking tokio v1.35.1 [INFO] [stderr] Checking rustix v0.37.27 [INFO] [stderr] Checking rand_core v0.6.4 [INFO] [stderr] Compiling cc v1.0.83 [INFO] [stderr] Checking tracing v0.1.40 [INFO] [stderr] Checking polling v2.8.0 [INFO] [stderr] Checking socket2 v0.4.10 [INFO] [stderr] Checking event-listener v3.1.0 [INFO] [stderr] Checking blocking v1.5.1 [INFO] [stderr] Compiling anyhow v1.0.79 [INFO] [stderr] Checking rand_chacha v0.3.1 [INFO] [stderr] Checking kv-log-macro v1.0.7 [INFO] [stderr] Compiling async-attributes v1.1.2 [INFO] [stderr] Checking rand v0.8.5 [INFO] [stderr] Compiling serde_derive_internals v0.26.0 [INFO] [stderr] Compiling schemars v0.8.16 [INFO] [stderr] Compiling ring v0.17.7 [INFO] [stderr] Checking lazy_static v1.4.0 [INFO] [stderr] Checking const-oid v0.9.6 [INFO] [stderr] Checking allocator-api2 v0.2.16 [INFO] [stderr] Checking zenoh-result v0.10.0-rc [INFO] [stderr] Checking nanorand v0.7.0 [INFO] [stderr] Checking async-io v1.13.0 [INFO] [stderr] Checking hashbrown v0.14.3 [INFO] [stderr] Checking hashbrown v0.13.2 [INFO] [stderr] Compiling aho-corasick v1.1.2 [INFO] [stderr] Compiling schemars_derive v0.8.16 [INFO] [stderr] Checking futures-channel v0.3.30 [INFO] [stderr] Checking serde_json v1.0.111 [INFO] [stderr] Checking zenoh-collections v0.10.0-rc [INFO] [stderr] Checking no-std-net v0.6.0 [INFO] [stderr] Checking dyn-clone v1.0.16 [INFO] [stderr] Compiling regex-syntax v0.8.2 [INFO] [stderr] Checking zenoh-buffers v0.10.0-rc [INFO] [stderr] Checking futures-util v0.3.30 [INFO] [stderr] Checking pnet_base v0.34.0 [INFO] [stderr] Checking keyed-set v0.4.5 [INFO] [stderr] Checking token-cell v1.5.0 [INFO] [stderr] Checking digest v0.10.7 [INFO] [stderr] Checking uhlc v0.6.3 [INFO] [stderr] Compiling ring v0.16.20 [INFO] [stderr] Checking uuid v1.6.1 [INFO] [stderr] Checking polling v3.3.1 [INFO] [stderr] Checking pnet_macros_support v0.34.0 [INFO] [stderr] Checking flume v0.11.0 [INFO] [stderr] Checking async-io v2.2.2 [INFO] [stderr] Checking pnet_sys v0.34.0 [INFO] [stderr] Compiling indexmap v1.9.3 [INFO] [stderr] Checking ipnetwork v0.20.0 [INFO] [stderr] Checking os_str_bytes v6.6.1 [INFO] [stderr] Checking async-signal v0.2.5 [INFO] [stderr] Checking async-global-executor v2.4.1 [INFO] [stderr] Compiling regex-automata v0.4.3 [INFO] [stderr] Checking async-process v1.8.1 [INFO] [stderr] Compiling pnet v0.34.0 [INFO] [stderr] Checking async-std v1.12.0 [INFO] [stderr] Checking zenoh-keyexpr v0.10.0-rc [INFO] [stderr] Checking clap_lex v0.2.4 [INFO] [stderr] Checking pnet_datalink v0.34.0 [INFO] [stderr] Checking sct v0.7.1 [INFO] [stderr] Checking atty v0.2.14 [INFO] [stderr] Checking textwrap v0.16.0 [INFO] [stderr] Checking shellexpand v3.1.0 [INFO] [stderr] Checking futures-executor v0.3.30 [INFO] [stderr] Checking libloading v0.8.1 [INFO] [stderr] Checking futures v0.3.30 [INFO] [stderr] Checking clap v3.2.25 [INFO] [stderr] Checking home v0.5.9 [INFO] [stderr] Compiling unzip-n v0.1.2 [INFO] [stderr] Compiling libm v0.2.8 [INFO] [stderr] Compiling rustls v0.21.10 [INFO] [stderr] Checking zenoh-protocol v0.10.0-rc [INFO] [stderr] Compiling semver v1.0.21 [INFO] [stderr] Checking rustls-webpki v0.101.7 [INFO] [stderr] Checking ntex-bytes v0.1.21 [INFO] [stderr] Compiling num-traits v0.2.17 [INFO] [stderr] Checking indexmap v2.1.0 [INFO] [stderr] Checking zenoh-codec v0.10.0-rc [INFO] [stderr] Checking oneshot v0.1.6 [INFO] [stderr] Checking zenoh-core v0.10.0-rc [INFO] [stderr] Compiling regex v1.10.2 [INFO] [stderr] Checking zenoh-sync v0.10.0-rc [INFO] [stderr] Checking zeroize v1.7.0 [INFO] [stderr] Compiling zerocopy v0.7.32 [INFO] [stderr] Checking base64ct v1.6.0 [INFO] [stderr] Checking zenoh-link-commons v0.10.0-rc [INFO] [stderr] Compiling rustc_version v0.4.0 [INFO] [stderr] Checking ntex-rt v0.4.11 [INFO] [stderr] Checking pem-rfc7468 v0.7.0 [INFO] [stderr] Checking json5 v0.4.1 [INFO] [stderr] Compiling validated_struct_macros v2.1.0 [INFO] [stderr] Compiling num-integer v0.1.45 [INFO] [stderr] Checking ntex-service v0.3.3 [INFO] [stderr] Checking unsafe-libyaml v0.2.10 [INFO] [stderr] Checking der v0.7.8 [INFO] [stderr] Checking ntex-codec v0.6.2 [INFO] [stderr] Checking sha1 v0.10.6 [INFO] [stderr] Checking ntex-util v0.1.19 [INFO] [stderr] Checking webpki v0.22.4 [INFO] [stderr] Compiling num-iter v0.1.43 [INFO] [stderr] Compiling rustls v0.20.9 [INFO] [stderr] Checking serde_yaml v0.9.30 [INFO] [stderr] Checking data-encoding v2.5.0 [INFO] [stderr] Checking utf-8 v0.7.6 [INFO] [stderr] Checking quinn-proto v0.10.6 [INFO] [stderr] Checking validated_struct v2.1.0 [INFO] [stderr] Checking spki v0.7.3 [INFO] [stderr] Checking tungstenite v0.20.1 [INFO] [stderr] Checking ntex-io v0.1.11 [INFO] [stderr] Checking async-rustls v0.4.2 [INFO] [stderr] Compiling pnet_macros v0.34.0 [INFO] [stderr] Checking inout v0.1.3 [INFO] [stderr] Checking quinn-udp v0.4.1 [INFO] [stderr] Checking futures-micro v0.5.0 [INFO] [stderr] Compiling num-bigint-dig v0.8.4 [INFO] [stderr] Checking async-oneshot v0.5.9 [INFO] [stderr] Checking cipher v0.4.4 [INFO] [stderr] Checking tokio-tungstenite v0.20.1 [INFO] [stderr] Checking pkcs8 v0.10.2 [INFO] [stderr] Checking nix v0.27.1 [INFO] [stderr] Compiling zenoh-macros v0.10.0-rc [INFO] [stderr] Checking twox-hash v1.6.3 [INFO] [stderr] Checking sha3 v0.10.8 [INFO] [stderr] Checking pkcs1 v0.7.5 [INFO] [stderr] Checking aes v0.8.3 [INFO] [stderr] Checking ntex-async-std v0.1.1 [INFO] [stderr] Checking pnet_packet v0.34.0 [INFO] [stderr] Checking zenoh-link-unixsock_stream v0.10.0-rc [INFO] [stderr] Checking webpki-roots v0.22.6 [INFO] [stderr] Checking ntex-http v0.1.11 [INFO] [stderr] Checking hmac v0.12.1 [INFO] [stderr] Checking quinn v0.10.2 [INFO] [stderr] Checking signature v2.2.0 [INFO] [stderr] Checking array-init v2.1.0 [INFO] [stderr] Checking cache-padded v1.3.0 [INFO] [stderr] Checking zenoh-crypto v0.10.0-rc [INFO] [stderr] Checking lz4_flex v0.11.1 [INFO] [stderr] Checking ringbuffer-spsc v0.1.9 [INFO] [stderr] Compiling zenoh v0.10.0-rc [INFO] [stderr] Checking rsa v0.9.6 [INFO] [stderr] Checking is-terminal v0.4.10 [INFO] [stderr] Compiling git-version-macro v0.3.9 [INFO] [stderr] Checking fixedbitset v0.4.2 [INFO] [stderr] Checking ntex-tls v0.1.7 [INFO] [stderr] Checking env_logger v0.10.1 [INFO] [stderr] Checking ntex-router v0.5.2 [INFO] [stderr] Checking petgraph v0.6.4 [INFO] [stderr] Checking ordered-float v3.9.2 [INFO] [stderr] Checking ntex-connect v0.1.1 [INFO] [stderr] Checking serde_urlencoded v0.7.1 [INFO] [stderr] Checking sha-1 v0.10.1 [INFO] [stderr] Checking ntex-h2 v0.1.6 [INFO] [stderr] Checking stop-token v0.7.0 [INFO] [stderr] Compiling ntex-macros v0.1.3 [INFO] [stderr] Compiling derive_more v0.99.17 [INFO] [stderr] Checking git-version v0.3.9 [INFO] [stderr] Compiling zenoh-plugin-mqtt v0.10.0-rc (/opt/rustwide/workdir) [INFO] [stderr] Checking bincode v1.3.3 [INFO] [stderr] Checking flume v0.10.14 [INFO] [stderr] Checking ntex v0.5.31 [INFO] [stderr] Checking pnet_transport v0.34.0 [INFO] [stderr] Checking zenoh-util v0.10.0-rc [INFO] [stderr] Checking zenoh-config v0.10.0-rc [INFO] [stderr] Checking zenoh-link-ws v0.10.0-rc [INFO] [stderr] Checking zenoh-link-udp v0.10.0-rc [INFO] [stderr] Checking zenoh-link-tcp v0.10.0-rc [INFO] [stderr] Checking zenoh-plugin-trait v0.10.0-rc [INFO] [stderr] Checking zenoh-link-quic v0.10.0-rc [INFO] [stderr] Checking zenoh-link-tls v0.10.0-rc [INFO] [stderr] Checking zenoh-link v0.10.0-rc [INFO] [stderr] Checking zenoh-transport v0.10.0-rc [INFO] [stderr] Checking ntex-mqtt v0.9.2 [INFO] [stderr] Checking zenoh-ext v0.10.0-rc [INFO] [stdout] error: internal compiler error: no errors encountered even though `span_delayed_bug` issued [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error: internal compiler error: broken MIR in Item(DefId(0:166 ~ zenoh_plugin_mqtt[eedc]::run::{closure#0}::{closure#1})) (after phase change to runtime-optimized) at bb4[7]: [INFO] [stdout] Failed subtyping Closure( [INFO] [stdout] DefId(0:167 ~ zenoh_plugin_mqtt[eedc]::run::{closure#0}::{closure#1}::{closure#0}), [INFO] [stdout] [ [INFO] [stdout] i8, [INFO] [stdout] Binder(extern "RustCall" fn((ntex::server::Config,)) -> ntex_mqtt::MqttServer>, ntex_mqtt::v3::server::HandshakeFactory, ntex::service::dev::FnServiceConfig ntex::util::Ready Coroutine(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased]), (ntex_mqtt::v3::Handshake, std::sync::Arc, std::sync::Arc)], Static), []), (std::sync::Arc, std::sync::Arc)]), Coroutine(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased]), (ntex_mqtt::v3::Handshake, std::sync::Arc, std::sync::Arc)], Static), ntex_mqtt::v3::Handshake, ntex_mqtt::v3::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ()>, []), (std::sync::Arc, std::sync::Arc)]), ntex::util::Ready Coroutine(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased]), (ntex_mqtt::v3::Handshake, std::sync::Arc, std::sync::Arc)], Static), []), (std::sync::Arc, std::sync::Arc)]), Coroutine(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased]), (ntex_mqtt::v3::Handshake, std::sync::Arc, std::sync::Arc)], Static), ntex_mqtt::v3::Handshake, ntex_mqtt::v3::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ()>, (), ntex::service::dev::FnServiceFactory Coroutine(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased]), (ntex_mqtt::v3::Handshake, std::sync::Arc, std::sync::Arc)], Static), []), (std::sync::Arc, std::sync::Arc)]), Coroutine(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:191 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{closure#0}), [ReErased]), (ntex_mqtt::v3::Handshake, std::sync::Arc, std::sync::Arc)], Static), ntex_mqtt::v3::Handshake, ntex_mqtt::v3::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Handshake, ()>>, ntex::service::dev::FnServiceConfig, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, MqttPluginError, i8, Binder(extern "RustCall" fn((ntex_mqtt::Session>,)) -> Coroutine(DefId(151:831 ~ ntex_mqtt[eee3]::v3::dispatcher::factory::{closure#0}::{closure#0}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, MqttPluginError, std::future::ResumeTy, (), std::result::Result, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex::util::buffer::BufferService, ntex::util::inflight::InFlightService,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, Closure(DefId(151:834 ~ ntex_mqtt[eee3]::v3::dispatcher::factory::{closure#0}::{closure#0}::{closure#2}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, MqttPluginError, i8, Binder(extern "RustCall" fn((MqttPluginError,)) -> ntex_mqtt::MqttError, []), ()]), ntex_mqtt::MqttError>>, ntex_mqtt::MqttError>, MqttPluginError>>, ntex_mqtt::MqttError>, CoroutineWitness(DefId(151:831 ~ ntex_mqtt[eee3]::v3::dispatcher::factory::{closure#0}::{closure#0}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, MqttPluginError]), (Coroutine(DefId(94:298 ~ ntex_util[54cb]::future::join::join::{closure#0}), [ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, std::future::ResumeTy, (), (std::result::Result Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, std::result::Result,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>), CoroutineWitness(DefId(94:298 ~ ntex_util[54cb]::future::join::join::{closure#0}), [ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>]), (ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>)], Static), u16, usize, ntex_mqtt::Session>, ntex_mqtt::v3::QoS)], Static), []), (ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, u16, usize, ntex_mqtt::v3::QoS)]), Coroutine(DefId(151:831 ~ ntex_mqtt[eee3]::v3::dispatcher::factory::{closure#0}::{closure#0}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, MqttPluginError, std::future::ResumeTy, (), std::result::Result, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex::util::buffer::BufferService, ntex::util::inflight::InFlightService,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, Closure(DefId(151:834 ~ ntex_mqtt[eee3]::v3::dispatcher::factory::{closure#0}::{closure#0}::{closure#2}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, MqttPluginError, i8, Binder(extern "RustCall" fn((MqttPluginError,)) -> ntex_mqtt::MqttError, []), ()]), ntex_mqtt::MqttError>>, ntex_mqtt::MqttError>, MqttPluginError>>, ntex_mqtt::MqttError>, CoroutineWitness(DefId(151:831 ~ ntex_mqtt[eee3]::v3::dispatcher::factory::{closure#0}::{closure#0}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, MqttPluginError]), (Coroutine(DefId(94:298 ~ ntex_util[54cb]::future::join::join::{closure#0}), [ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, std::future::ResumeTy, (), (std::result::Result Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, std::result::Result,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>), CoroutineWitness(DefId(94:298 ~ ntex_util[54cb]::future::join::join::{closure#0}), [ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>]), (ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>)], Static), u16, usize, ntex_mqtt::Session>, ntex_mqtt::v3::QoS)], Static), ntex_mqtt::Session>, ntex_mqtt::inflight::InFlightService, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex::util::buffer::BufferService, ntex::util::inflight::InFlightService,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, Closure(DefId(151:834 ~ ntex_mqtt[eee3]::v3::dispatcher::factory::{closure#0}::{closure#0}::{closure#2}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result<(), MqttPluginError>, CoroutineWitness(DefId(0:193 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::Publish)], Static), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:195 ~ zenoh_plugin_mqtt[eedc]::control_v3::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v3::ControlMessage)], Static), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, MqttPluginError, i8, Binder(extern "RustCall" fn((MqttPluginError,)) -> ntex_mqtt::MqttError, []), ()]), ntex_mqtt::MqttError>>, ntex_mqtt::MqttError>, MqttPluginError>>, ntex::io::DispatchItem>, ntex_mqtt::MqttError>, std::rc::Rc>, ntex_mqtt::service::MqttServer>, ntex_mqtt::v5::server::HandshakeFactory, ntex::service::dev::FnServiceConfig ntex::util::Ready Coroutine(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased]), (ntex_mqtt::v5::Handshake, std::sync::Arc, std::sync::Arc)], Static), []), (std::sync::Arc, std::sync::Arc)]), Coroutine(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased]), (ntex_mqtt::v5::Handshake, std::sync::Arc, std::sync::Arc)], Static), ntex_mqtt::v5::Handshake, ntex_mqtt::v5::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ()>, []), (std::sync::Arc, std::sync::Arc)]), ntex::util::Ready Coroutine(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased]), (ntex_mqtt::v5::Handshake, std::sync::Arc, std::sync::Arc)], Static), []), (std::sync::Arc, std::sync::Arc)]), Coroutine(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased]), (ntex_mqtt::v5::Handshake, std::sync::Arc, std::sync::Arc)], Static), ntex_mqtt::v5::Handshake, ntex_mqtt::v5::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ()>, (), ntex::service::dev::FnServiceFactory Coroutine(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased]), (ntex_mqtt::v5::Handshake, std::sync::Arc, std::sync::Arc)], Static), []), (std::sync::Arc, std::sync::Arc)]), Coroutine(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased, std::future::ResumeTy, (), std::result::Result>, MqttPluginError>, CoroutineWitness(DefId(0:198 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{closure#0}), [ReErased]), (ntex_mqtt::v5::Handshake, std::sync::Arc, std::sync::Arc)], Static), ntex_mqtt::v5::Handshake, ntex_mqtt::v5::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Handshake, ()>>, ntex::service::dev::FnServiceConfig, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, MqttPluginError>, MqttPluginError, i8, Binder(extern "RustCall" fn((ntex_mqtt::Session>,)) -> Coroutine(DefId(151:2586 ~ ntex_mqtt[eee3]::v5::dispatcher::factory::{closure#0}::{closure#0}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, MqttPluginError>, MqttPluginError, std::future::ResumeTy, (), std::result::Result Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex::util::buffer::BufferService, ntex::util::inflight::InFlightService,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, Closure(DefId(151:2589 ~ ntex_mqtt[eee3]::v5::dispatcher::factory::{closure#0}::{closure#0}::{closure#2}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, MqttPluginError>, MqttPluginError, i8, Binder(extern "RustCall" fn((MqttPluginError,)) -> ntex_mqtt::MqttError, []), ()]), ntex_mqtt::MqttError>>, ntex_mqtt::MqttError>, MqttPluginError>>, ntex_mqtt::MqttError>, CoroutineWitness(DefId(151:2586 ~ ntex_mqtt[eee3]::v5::dispatcher::factory::{closure#0}::{closure#0}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, MqttPluginError>, MqttPluginError]), (Coroutine(DefId(94:298 ~ ntex_util[54cb]::future::join::join::{closure#0}), [ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, std::future::ResumeTy, (), (std::result::Result Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, std::result::Result,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>), CoroutineWitness(DefId(94:298 ~ ntex_util[54cb]::future::join::join::{closure#0}), [ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>]), (ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>)], Static), usize, ntex_mqtt::Session>, ntex_mqtt::v3::QoS, u16, u16)], Static), []), (ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, MqttPluginError>, usize, ntex_mqtt::v3::QoS)]), Coroutine(DefId(151:2586 ~ ntex_mqtt[eee3]::v5::dispatcher::factory::{closure#0}::{closure#0}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, MqttPluginError>, MqttPluginError, std::future::ResumeTy, (), std::result::Result Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex::util::buffer::BufferService, ntex::util::inflight::InFlightService,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, Closure(DefId(151:2589 ~ ntex_mqtt[eee3]::v5::dispatcher::factory::{closure#0}::{closure#0}::{closure#2}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, MqttPluginError>, MqttPluginError, i8, Binder(extern "RustCall" fn((MqttPluginError,)) -> ntex_mqtt::MqttError, []), ()]), ntex_mqtt::MqttError>>, ntex_mqtt::MqttError>, MqttPluginError>>, ntex_mqtt::MqttError>, CoroutineWitness(DefId(151:2586 ~ ntex_mqtt[eee3]::v5::dispatcher::factory::{closure#0}::{closure#0}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, MqttPluginError>, MqttPluginError]), (Coroutine(DefId(94:298 ~ ntex_util[54cb]::future::join::join::{closure#0}), [ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, std::future::ResumeTy, (), (std::result::Result Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, std::result::Result,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>), CoroutineWitness(DefId(94:298 ~ ntex_util[54cb]::future::join::join::{closure#0}), [ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>]), (ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>)], Static), usize, ntex_mqtt::Session>, ntex_mqtt::v3::QoS, u16, u16)], Static), ntex_mqtt::Session>, ntex_mqtt::inflight::InFlightService Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex::util::buffer::BufferService, ntex::util::inflight::InFlightService,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, Closure(DefId(151:2589 ~ ntex_mqtt[eee3]::v5::dispatcher::factory::{closure#0}::{closure#0}::{closure#2}), [mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:200 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::Publish)], Static), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Publish, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), []), (ntex_mqtt::Session>,)]), Coroutine(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), [std::future::ResumeTy, (), std::result::Result, CoroutineWitness(DefId(0:203 ~ zenoh_plugin_mqtt[eedc]::control_v5::{closure#0}), []), (ntex_mqtt::Session>, ntex_mqtt::v5::ControlMessage)], Static), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, MqttPluginError>, MqttPluginError, i8, Binder(extern "RustCall" fn((MqttPluginError,)) -> ntex_mqtt::MqttError, []), ()]), ntex_mqtt::MqttError>>, ntex_mqtt::MqttError>, MqttPluginError>>, ntex::io::DispatchItem>, ntex_mqtt::MqttError>, std::rc::Rc>, MqttPluginError, ()>, []), [INFO] [stdout] (std::sync::Arc, std::sync::Arc), [INFO] [stdout] ], [INFO] [stdout] ) and Closure( [INFO] [stdout] DefId(0:167 ~ zenoh_plugin_mqtt[eedc]::run::{closure#0}::{closure#1}::{closure#0}), [INFO] [stdout] [ [INFO] [stdout] i8, [INFO] [stdout] Binder(extern "RustCall" fn((ntex::server::Config,)) -> ntex_mqtt::MqttServer, ntex_mqtt::server::DefaultProtocolServer, MqttPluginError, (), mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), []), (std::sync::Arc, std::sync::Arc)]), Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), ntex_mqtt::v3::Handshake, ntex_mqtt::v3::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ()>, []), (std::sync::Arc, std::sync::Arc)]), ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), []), (std::sync::Arc, std::sync::Arc)]), Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), ntex_mqtt::v3::Handshake, ntex_mqtt::v3::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ()>, (), ntex::service::dev::FnServiceFactory Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), []), (std::sync::Arc, std::sync::Arc)]), Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), ntex_mqtt::v3::Handshake, ntex_mqtt::v3::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Handshake, ()>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>], def_id: DefId(151:7453 ~ ntex_mqtt[eee3]::server::{impl#3}::v3::{opaque#0}) }), Alias(Opaque, AliasTy { args: [Alias(Opaque, AliasTy { args: [ntex_mqtt::server::DefaultProtocolServer, ntex_mqtt::server::DefaultProtocolServer, MqttPluginError, (), mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), []), (std::sync::Arc, std::sync::Arc)]), Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), ntex_mqtt::v3::Handshake, ntex_mqtt::v3::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ()>, []), (std::sync::Arc, std::sync::Arc)]), ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), []), (std::sync::Arc, std::sync::Arc)]), Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), ntex_mqtt::v3::Handshake, ntex_mqtt::v3::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ()>, (), ntex::service::dev::FnServiceFactory Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), []), (std::sync::Arc, std::sync::Arc)]), Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:484 ~ zenoh_plugin_mqtt[eedc]::handshake_v3::{opaque#0}) }), ntex_mqtt::v3::Handshake, ntex_mqtt::v3::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Handshake, ()>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:490 ~ zenoh_plugin_mqtt[eedc]::control_v3::{opaque#0}) }), ntex_mqtt::v3::ControlMessage, ntex_mqtt::v3::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::ControlMessage, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:487 ~ zenoh_plugin_mqtt[eedc]::publish_v3::{opaque#0}) }), ntex_mqtt::v3::Publish, (), MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v3::Publish, MqttPluginError>], def_id: DefId(151:7453 ~ ntex_mqtt[eee3]::server::{impl#3}::v3::{opaque#0}) }), ntex_mqtt::server::DefaultProtocolServer, MqttPluginError, (), mqtt_session_state::MqttSessionState, ntex::service::dev::FnServiceConfig ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:492 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{opaque#0}) }), []), (std::sync::Arc, std::sync::Arc)]), Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:492 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{opaque#0}) }), ntex_mqtt::v5::Handshake, ntex_mqtt::v5::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ()>, []), (std::sync::Arc, std::sync::Arc)]), ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:492 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{opaque#0}) }), []), (std::sync::Arc, std::sync::Arc)]), Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:492 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{opaque#0}) }), ntex_mqtt::v5::Handshake, ntex_mqtt::v5::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ()>, (), ntex::service::dev::FnServiceFactory Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:492 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{opaque#0}) }), []), (std::sync::Arc, std::sync::Arc)]), Alias(Opaque, AliasTy { args: [ReErased, ReErased], def_id: DefId(0:492 ~ zenoh_plugin_mqtt[eedc]::handshake_v5::{opaque#0}) }), ntex_mqtt::v5::Handshake, ntex_mqtt::v5::HandshakeAck>, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Handshake, ()>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready,)) -> Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:498 ~ zenoh_plugin_mqtt[eedc]::control_v5::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:498 ~ zenoh_plugin_mqtt[eedc]::control_v5::{opaque#0}) }), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready,)) -> Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:498 ~ zenoh_plugin_mqtt[eedc]::control_v5::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:498 ~ zenoh_plugin_mqtt[eedc]::control_v5::{opaque#0}) }), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory,)) -> Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:498 ~ zenoh_plugin_mqtt[eedc]::control_v5::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:498 ~ zenoh_plugin_mqtt[eedc]::control_v5::{opaque#0}) }), ntex_mqtt::v5::ControlMessage, ntex_mqtt::v5::ControlResult, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::ControlMessage, MqttPluginError>, ntex::service::dev::FnServiceConfig>,)) -> ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:495 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:495 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{opaque#0}) }), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, []), ()]), ntex::util::Ready Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:495 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:495 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{opaque#0}) }), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, MqttPluginError>, ntex_mqtt::Session>, ntex::service::dev::FnServiceFactory Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:495 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{opaque#0}) }), []), (ntex_mqtt::Session>,)]), Alias(Opaque, AliasTy { args: [ReErased], def_id: DefId(0:495 ~ zenoh_plugin_mqtt[eedc]::publish_v5::{opaque#0}) }), ntex_mqtt::v5::Publish, ntex_mqtt::v5::PublishAck, MqttPluginError, (), Binder(fn(), [])>, ntex_mqtt::v5::Publish, MqttPluginError>], def_id: DefId(151:7455 ~ ntex_mqtt[eee3]::server::{impl#3}::v5::{opaque#0}) }), MqttPluginError, ()>, []), [INFO] [stdout] (std::sync::Arc, std::sync::Arc), [INFO] [stdout] ], [INFO] [stdout] ) [INFO] [stdout] --> src/lib.rs:148:52 [INFO] [stdout] | [INFO] [stdout] 148 | .bind("mqtt", config.port.clone(), move |_| { [INFO] [stdout] | ____________________________________________________^ [INFO] [stdout] 149 | | let zs_v3 = zsession.clone(); [INFO] [stdout] 150 | | let zs_v5 = zsession.clone(); [INFO] [stdout] 151 | | let config_v3 = config.clone(); [INFO] [stdout] ... | [INFO] [stdout] 195 | | ))) [INFO] [stdout] 196 | | })? [INFO] [stdout] | |_________________^ [INFO] [stdout] | [INFO] [stdout] note: delayed at compiler/rustc_const_eval/src/transform/validate.rs:96:25 [INFO] [stdout] 0: ::emit_diagnostic_without_consuming [INFO] [stdout] 1: ::emit_diagnostic [INFO] [stdout] 2: ::span_delayed_bug:: [INFO] [stdout] 3: ::fail:: [INFO] [stdout] 4: ::run_pass [INFO] [stdout] 5: rustc_mir_transform::pass_manager::run_passes_inner [INFO] [stdout] 6: rustc_mir_transform::optimized_mir [INFO] [stdout] 7: rustc_query_impl::plumbing::__rust_begin_short_backtrace::> [INFO] [stdout] 8: rustc_query_system::query::plumbing::try_execute_query::>, false, false, false>, rustc_query_impl::plumbing::QueryCtxt, false> [INFO] [stdout] 9: rustc_query_impl::query_impl::optimized_mir::get_query_non_incr::__rust_end_short_backtrace [INFO] [stdout] 10: rustc_middle::query::plumbing::query_get_at::>> [INFO] [stdout] 11: ::encode_crate_root [INFO] [stdout] 12: rustc_metadata::rmeta::encoder::encode_metadata [INFO] [stdout] 13: rustc_metadata::fs::encode_and_write_metadata [INFO] [stdout] 14: rustc_interface::passes::start_codegen [INFO] [stdout] 15: ::codegen_and_build_linker [INFO] [stdout] 16: rustc_interface::interface::run_compiler::, rustc_driver_impl::run_compiler::{closure#0}>::{closure#0} [INFO] [stdout] 17: std::sys_common::backtrace::__rust_begin_short_backtrace::, rustc_driver_impl::run_compiler::{closure#0}>::{closure#0}, core::result::Result<(), rustc_span::ErrorGuaranteed>>::{closure#0}, core::result::Result<(), rustc_span::ErrorGuaranteed>>::{closure#0}::{closure#0}, core::result::Result<(), rustc_span::ErrorGuaranteed>> [INFO] [stdout] 18: <::spawn_unchecked_, rustc_driver_impl::run_compiler::{closure#0}>::{closure#0}, core::result::Result<(), rustc_span::ErrorGuaranteed>>::{closure#0}, core::result::Result<(), rustc_span::ErrorGuaranteed>>::{closure#0}::{closure#0}, core::result::Result<(), rustc_span::ErrorGuaranteed>>::{closure#1} as core::ops::function::FnOnce<()>>::call_once::{shim:vtable#0} [INFO] [stdout] 19: as core::ops::function::FnOnce>::call_once [INFO] [stdout] at /rustc/2eb702bf20a12c67e5629a5c82890c910c267bd9/library/alloc/src/boxed.rs:2015:9 [INFO] [stdout] 20: as core::ops::function::FnOnce>::call_once [INFO] [stdout] at /rustc/2eb702bf20a12c67e5629a5c82890c910c267bd9/library/alloc/src/boxed.rs:2015:9 [INFO] [stdout] 21: std::sys::unix::thread::Thread::new::thread_start [INFO] [stdout] at /rustc/2eb702bf20a12c67e5629a5c82890c910c267bd9/library/std/src/sys/unix/thread.rs:108:17 [INFO] [stdout] 22: [INFO] [stdout] 23: __clone [INFO] [stdout] --> src/lib.rs:148:52 [INFO] [stdout] | [INFO] [stdout] 148 | .bind("mqtt", config.port.clone(), move |_| { [INFO] [stdout] | ____________________________________________________^ [INFO] [stdout] 149 | | let zs_v3 = zsession.clone(); [INFO] [stdout] 150 | | let zs_v5 = zsession.clone(); [INFO] [stdout] 151 | | let config_v3 = config.clone(); [INFO] [stdout] ... | [INFO] [stdout] 195 | | ))) [INFO] [stdout] 196 | | })? [INFO] [stdout] | |_________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] note: we would appreciate a bug report: https://github.com/rust-lang/rust/issues/new?labels=C-bug%2C+I-ICE%2C+T-compiler&template=ice.md [INFO] [stderr] [INFO] [stderr] warning: the ICE couldn't be written to `/opt/rustwide/workdir/rustc-ice-2024-01-09T02_57_11-1709.txt`: Read-only file system (os error 30) [INFO] [stderr] [INFO] [stderr] note: rustc 1.76.0-nightly (2eb702bf2 2023-12-18) running on x86_64-unknown-linux-gnu [INFO] [stderr] [INFO] [stderr] note: compiler flags: --crate-type cdylib --crate-type rlib -C embed-bitcode=no -C debuginfo=2 [INFO] [stderr] [INFO] [stderr] note: some of the compiler flags provided by cargo are hidden [INFO] [stderr] [INFO] [stderr] query stack during panic: [INFO] [stderr] end of query stack [INFO] [stderr] error: could not compile `zenoh-plugin-mqtt` (lib) [INFO] running `Command { std: "docker" "inspect" "3add12c5707bbc83ed6e7eaf37e917d6b9355781308a3aed54b347775d89f782", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "3add12c5707bbc83ed6e7eaf37e917d6b9355781308a3aed54b347775d89f782", kill_on_drop: false }` [INFO] [stdout] 3add12c5707bbc83ed6e7eaf37e917d6b9355781308a3aed54b347775d89f782