[INFO] fetching crate async-nats-wrpc 0.35.1... [INFO] testing async-nats-wrpc-0.35.1 against try#c2e32f1c9652b13ed99608599c1e855462f421f3 for pr-146098-7 [INFO] extracting crate async-nats-wrpc 0.35.1 into /workspace/builds/worker-0-tc2/source [INFO] started tweaking crates.io crate async-nats-wrpc 0.35.1 [INFO] finished tweaking crates.io crate async-nats-wrpc 0.35.1 [INFO] tweaked toml for crates.io crate async-nats-wrpc 0.35.1 written to /workspace/builds/worker-0-tc2/source/Cargo.toml [INFO] validating manifest of crates.io crate async-nats-wrpc 0.35.1 on toolchain c2e32f1c9652b13ed99608599c1e855462f421f3 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+c2e32f1c9652b13ed99608599c1e855462f421f3" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate crates.io crate async-nats-wrpc 0.35.1 already has a lockfile, it will not be regenerated [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+c2e32f1c9652b13ed99608599c1e855462f421f3" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c2e32f1c9652b13ed99608599c1e855462f421f3" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] c5af3e4d1ecd1ea0eca73c54e127dfe4b5878f00fe2fdacdfda7579e311573e4 [INFO] running `Command { std: "docker" "start" "-a" "c5af3e4d1ecd1ea0eca73c54e127dfe4b5878f00fe2fdacdfda7579e311573e4", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "c5af3e4d1ecd1ea0eca73c54e127dfe4b5878f00fe2fdacdfda7579e311573e4", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "c5af3e4d1ecd1ea0eca73c54e127dfe4b5878f00fe2fdacdfda7579e311573e4", kill_on_drop: false }` [INFO] [stdout] c5af3e4d1ecd1ea0eca73c54e127dfe4b5878f00fe2fdacdfda7579e311573e4 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c2e32f1c9652b13ed99608599c1e855462f421f3" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] ad1a0fc083920ff279197ca8292771622f4de6baf37fa1a0b0191638929b5c43 [INFO] running `Command { std: "docker" "start" "-a" "ad1a0fc083920ff279197ca8292771622f4de6baf37fa1a0b0191638929b5c43", kill_on_drop: false }` [INFO] [stderr] Compiling proc-macro2 v1.0.83 [INFO] [stderr] Compiling serde v1.0.202 [INFO] [stderr] Compiling semver v1.0.23 [INFO] [stderr] Compiling zeroize v1.7.0 [INFO] [stderr] Compiling cc v1.0.98 [INFO] [stderr] Compiling memchr v2.7.2 [INFO] [stderr] Compiling block-buffer v0.10.4 [INFO] [stderr] Compiling base64ct v1.6.0 [INFO] [stderr] Compiling platforms v3.4.0 [INFO] [stderr] Compiling digest v0.10.7 [INFO] [stderr] Compiling subtle v2.5.0 [INFO] [stderr] Compiling pem-rfc7468 v0.7.0 [INFO] [stderr] Compiling rustls-pki-types v1.7.0 [INFO] [stderr] Compiling signature v2.2.0 [INFO] [stderr] Compiling futures-channel v0.3.30 [INFO] [stderr] Compiling rustc_version v0.4.0 [INFO] [stderr] Compiling der v0.7.9 [INFO] [stderr] Compiling mio v0.8.11 [INFO] [stderr] Compiling curve25519-dalek v4.1.2 [INFO] [stderr] Compiling spin v0.9.8 [INFO] [stderr] Compiling tinyvec v1.6.0 [INFO] [stderr] Compiling rustls v0.23.7 [INFO] [stderr] Compiling quote v1.0.36 [INFO] [stderr] Compiling rand v0.8.5 [INFO] [stderr] Compiling sha2 v0.10.8 [INFO] [stderr] Compiling syn v2.0.65 [INFO] [stderr] Compiling aho-corasick v1.1.3 [INFO] [stderr] Compiling ed25519 v2.2.3 [INFO] [stderr] Compiling thiserror v1.0.61 [INFO] [stderr] Compiling ring v0.17.8 [INFO] [stderr] Compiling regex-syntax v0.8.3 [INFO] [stderr] Compiling unicode-normalization v0.1.23 [INFO] [stderr] Compiling portable-atomic v1.6.0 [INFO] [stderr] Compiling serde_json v1.0.117 [INFO] [stderr] Compiling idna v0.5.0 [INFO] [stderr] Compiling rustls-pemfile v2.1.2 [INFO] [stderr] Compiling log v0.4.21 [INFO] [stderr] Compiling spki v0.7.3 [INFO] [stderr] Compiling time-core v0.1.2 [INFO] [stderr] Compiling data-encoding v2.6.0 [INFO] [stderr] Compiling pkcs8 v0.10.2 [INFO] [stderr] Compiling signatory v0.27.1 [INFO] [stderr] Compiling url v2.5.0 [INFO] [stderr] Compiling rustls-native-certs v0.7.0 [INFO] [stderr] Compiling nuid v0.5.0 [INFO] [stderr] Compiling regex-automata v0.4.6 [INFO] [stderr] Compiling rustls-webpki v0.102.4 [INFO] [stderr] Compiling serde_derive v1.0.202 [INFO] [stderr] Compiling futures-macro v0.3.30 [INFO] [stderr] Compiling tokio-macros v2.2.0 [INFO] [stderr] Compiling curve25519-dalek-derive v0.1.1 [INFO] [stderr] Compiling tracing-attributes v0.1.27 [INFO] [stderr] Compiling thiserror-impl v1.0.61 [INFO] [stderr] Compiling serde_repr v0.1.19 [INFO] [stderr] Compiling futures-util v0.3.30 [INFO] [stderr] Compiling regex v1.10.4 [INFO] [stderr] Compiling ed25519-dalek v2.1.1 [INFO] [stderr] Compiling tracing v0.1.40 [INFO] [stderr] Compiling nkeys v0.4.1 [INFO] [stderr] Compiling futures-executor v0.3.30 [INFO] [stderr] Compiling futures v0.3.30 [INFO] [stderr] Compiling bytes v1.6.0 [INFO] [stderr] Compiling deranged v0.3.11 [INFO] [stderr] Compiling serde_nanos v0.1.4 [INFO] [stderr] Compiling tokio v1.37.0 [INFO] [stderr] Compiling time v0.3.36 [INFO] [stderr] Compiling tokio-util v0.7.11 [INFO] [stderr] Compiling tryhard v0.5.1 [INFO] [stderr] Compiling tokio-rustls v0.26.0 [INFO] [stderr] Compiling async-nats-wrpc v0.35.1 (/opt/rustwide/workdir) [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> src/header.rs:203:39 [INFO] [stdout] | [INFO] [stdout] 203 | pub fn get_all(&self, key: K) -> GetAll { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] = note: `#[warn(mismatched_lifetime_syntaxes)]` on by default [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 203 | pub fn get_all(&self, key: K) -> GetAll<'_, HeaderValue> { [INFO] [stdout] | +++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> src/jetstream/consumer/pull.rs:208:18 [INFO] [stdout] | [INFO] [stdout] 208 | pub fn fetch(&self) -> FetchBuilder { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 208 | pub fn fetch(&self) -> FetchBuilder<'_> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> src/jetstream/consumer/pull.rs:253:18 [INFO] [stdout] | [INFO] [stdout] 253 | pub fn batch(&self) -> BatchBuilder { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 253 | pub fn batch(&self) -> BatchBuilder<'_> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> src/jetstream/stream.rs:651:18 [INFO] [stdout] | [INFO] [stdout] 651 | pub fn purge(&self) -> Purge { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 651 | pub fn purge(&self) -> Purge<'_, No, No> { [INFO] [stdout] | +++ [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 1m 29s [INFO] running `Command { std: "docker" "inspect" "ad1a0fc083920ff279197ca8292771622f4de6baf37fa1a0b0191638929b5c43", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "ad1a0fc083920ff279197ca8292771622f4de6baf37fa1a0b0191638929b5c43", kill_on_drop: false }` [INFO] [stdout] ad1a0fc083920ff279197ca8292771622f4de6baf37fa1a0b0191638929b5c43 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c2e32f1c9652b13ed99608599c1e855462f421f3" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 3c32c2edaa930cd0b97080d1ba62a01d6a9e387d07409423e0cc2d3c8fa4869f [INFO] running `Command { std: "docker" "start" "-a" "3c32c2edaa930cd0b97080d1ba62a01d6a9e387d07409423e0cc2d3c8fa4869f", kill_on_drop: false }` [INFO] [stderr] Compiling num_cpus v1.16.0 [INFO] [stderr] Compiling openssl-sys v0.9.102 [INFO] [stderr] Compiling tracing-core v0.1.32 [INFO] [stderr] Compiling futures-util v0.3.30 [INFO] [stderr] Compiling log v0.4.21 [INFO] [stderr] Compiling openssl v0.10.64 [INFO] [stderr] Compiling http v0.2.12 [INFO] [stderr] Compiling openssl-macros v0.1.1 [INFO] [stderr] Compiling utf8parse v0.2.1 [INFO] [stderr] Compiling native-tls v0.2.11 [INFO] [stderr] Compiling httparse v1.8.0 [INFO] [stderr] Compiling bitflags v2.5.0 [INFO] [stderr] Compiling anstyle-parse v0.2.4 [INFO] [stderr] Compiling tokio v1.37.0 [INFO] [stderr] Compiling anstyle-query v1.0.3 [INFO] [stderr] Compiling anstream v0.6.14 [INFO] [stderr] Compiling tracing v0.1.40 [INFO] [stderr] Compiling http-body v0.4.6 [INFO] [stderr] Compiling num-bigint v0.4.5 [INFO] [stderr] Compiling either v1.12.0 [INFO] [stderr] Compiling clap_lex v0.7.0 [INFO] [stderr] Compiling clap_derive v4.5.4 [INFO] [stderr] Compiling time-macros v0.2.18 [INFO] [stderr] Compiling clap_builder v4.5.2 [INFO] [stderr] Compiling num-iter v0.1.45 [INFO] [stderr] Compiling num-complex v0.4.6 [INFO] [stderr] Compiling ahash v0.8.11 [INFO] [stderr] Compiling half v2.4.1 [INFO] [stderr] Compiling num-rational v0.4.2 [INFO] [stderr] Compiling plotters-backend v0.3.6 [INFO] [stderr] Compiling time v0.3.36 [INFO] [stderr] Compiling bit-set v0.5.3 [INFO] [stderr] Compiling plotters-svg v0.3.6 [INFO] [stderr] Compiling ciborium-ll v0.2.2 [INFO] [stderr] Compiling nom v7.1.3 [INFO] [stderr] Compiling num v0.4.3 [INFO] [stderr] Compiling futures-executor v0.3.30 [INFO] [stderr] Compiling parking_lot_core v0.9.10 [INFO] [stderr] Compiling futures v0.3.30 [INFO] [stderr] Compiling itertools v0.10.5 [INFO] [stderr] Compiling serde_urlencoded v0.7.1 [INFO] [stderr] Compiling zerocopy v0.7.34 [INFO] [stderr] Compiling clap v4.5.4 [INFO] [stderr] Compiling overload v0.1.1 [INFO] [stderr] Compiling sync_wrapper v0.1.2 [INFO] [stderr] Compiling nu-ansi-term v0.46.0 [INFO] [stderr] Compiling nkeys v0.4.1 [INFO] [stderr] Compiling parking_lot v0.12.2 [INFO] [stderr] Compiling rayon v1.10.0 [INFO] [stderr] Compiling tokio-util v0.7.11 [INFO] [stderr] Compiling criterion-plot v0.5.0 [INFO] [stderr] Compiling h2 v0.3.26 [INFO] [stderr] Compiling tokio-native-tls v0.3.1 [INFO] [stderr] Compiling iso8601 v0.6.1 [INFO] [stderr] Compiling tokio-rustls v0.26.0 [INFO] [stderr] Compiling tryhard v0.5.1 [INFO] [stderr] Compiling ciborium v0.2.2 [INFO] [stderr] Compiling fraction v0.13.1 [INFO] [stderr] Compiling plotters v0.3.6 [INFO] [stderr] Compiling fancy-regex v0.11.0 [INFO] [stderr] Compiling sharded-slab v0.1.7 [INFO] [stderr] Compiling tracing-log v0.2.0 [INFO] [stderr] Compiling tinytemplate v1.2.1 [INFO] [stderr] Compiling thread_local v1.1.8 [INFO] [stderr] Compiling is-terminal v0.4.12 [INFO] [stderr] Compiling bytecount v0.6.8 [INFO] [stderr] Compiling uuid v1.8.0 [INFO] [stderr] Compiling num-cmp v0.1.0 [INFO] [stderr] Compiling oorandom v11.1.3 [INFO] [stderr] Compiling criterion v0.5.1 [INFO] [stderr] Compiling tracing-subscriber v0.3.18 [INFO] [stderr] Compiling async-nats-wrpc v0.35.1 (/opt/rustwide/workdir) [INFO] [stderr] Compiling hyper v0.14.28 [INFO] [stderr] Compiling hyper-tls v0.5.0 [INFO] [stderr] Compiling reqwest v0.11.27 [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> src/header.rs:203:39 [INFO] [stdout] | [INFO] [stdout] 203 | pub fn get_all(&self, key: K) -> GetAll { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] = note: `#[warn(mismatched_lifetime_syntaxes)]` on by default [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 203 | pub fn get_all(&self, key: K) -> GetAll<'_, HeaderValue> { [INFO] [stdout] | +++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> src/jetstream/consumer/pull.rs:208:18 [INFO] [stdout] | [INFO] [stdout] 208 | pub fn fetch(&self) -> FetchBuilder { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 208 | pub fn fetch(&self) -> FetchBuilder<'_> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> src/jetstream/consumer/pull.rs:253:18 [INFO] [stdout] | [INFO] [stdout] 253 | pub fn batch(&self) -> BatchBuilder { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 253 | pub fn batch(&self) -> BatchBuilder<'_> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Compiling jsonschema v0.17.1 [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> src/jetstream/stream.rs:651:18 [INFO] [stdout] | [INFO] [stdout] 651 | pub fn purge(&self) -> Purge { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 651 | pub fn purge(&self) -> Purge<'_, No, No> { [INFO] [stdout] | +++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:17:9 [INFO] [stdout] | [INFO] [stdout] 17 | use async_nats::jetstream::{ [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> examples/jetstream_push.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use async_nats::jetstream::{self, consumer::PushConsumer}; [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `async_nats` [INFO] [stdout] --> examples/jetstream_push.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use async_nats::jetstream::{self, consumer::PushConsumer}; [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `async_nats` [INFO] [stdout] --> tests/jwt_tests.rs:59:13 [INFO] [stdout] | [INFO] [stdout] 59 | use async_nats::ServerAddr; [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `async_nats` [INFO] [stdout] --> examples/pub.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | use async_nats::{connect, Error, Subject}; [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:17:9 [INFO] [stdout] | [INFO] [stdout] 17 | use async_nats::{ [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> examples/pub.rs:20:9 [INFO] [stdout] | [INFO] [stdout] 20 | let client = connect("nats://localhost:4222").await?; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 26 | client.publish(subject.clone(), dat.clone()).await?; [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `client` an explicit type [INFO] [stdout] | [INFO] [stdout] 20 | let client: /* Type */ = connect("nats://localhost:4222").await?; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0282, E0432. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0282`. [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:17:9 [INFO] [stdout] | [INFO] [stdout] 17 | use async_nats::{ [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `async_nats` [INFO] [stdout] --> tests/nkey_tests.rs:52:13 [INFO] [stdout] | [INFO] [stdout] 52 | use async_nats::ServerAddr; [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] error: could not compile `async-nats-wrpc` (example "pub") due to 2 previous errors [INFO] [stderr] warning: build failed, waiting for other jobs to finish... [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> examples/jetstream_push.rs:11:18 [INFO] [stdout] | [INFO] [stdout] 11 | let client = async_nats::connect(nats_url).await?; [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> examples/jetstream_push.rs:11:9 [INFO] [stdout] | [INFO] [stdout] 11 | let client = async_nats::connect(nats_url).await?; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 12 | [INFO] [stdout] 13 | let inbox = client.new_inbox(); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `client` an explicit type [INFO] [stdout] | [INFO] [stdout] 11 | let client: /* Type */ = async_nats::connect(nats_url).await?; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> examples/jetstream_push.rs:23:34 [INFO] [stdout] | [INFO] [stdout] 23 | let consumer: PushConsumer = jetstream [INFO] [stdout] | __________________________________^ [INFO] [stdout] 24 | | .create_stream(jetstream::stream::Config { [INFO] [stdout] 25 | | name: stream_name, [INFO] [stdout] 26 | | subjects: vec!["events.>".to_string()], [INFO] [stdout] 27 | | ..Default::default() [INFO] [stdout] 28 | | }) [INFO] [stdout] 29 | | .await? [INFO] [stdout] | |_______________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> examples/jetstream_push.rs:51:24 [INFO] [stdout] | [INFO] [stdout] 51 | let mut messages = consumer.messages().await?.take(10); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> examples/jetstream_push.rs:6:31 [INFO] [stdout] | [INFO] [stdout] 6 | async fn main() -> Result<(), async_nats::Error> { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0282, E0432, E0433. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0282`. [INFO] [stdout] [INFO] [stderr] error: could not compile `async-nats-wrpc` (example "jetstream_push") due to 7 previous errors [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> examples/json.rs:20:18 [INFO] [stdout] | [INFO] [stdout] 20 | let client = async_nats::connect(nats_url).await?; [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> examples/json.rs:20:9 [INFO] [stdout] | [INFO] [stdout] 20 | let client = async_nats::connect(nats_url).await?; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 23 | let mut subscriber = client.subscribe("foo").await?.take(1); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `client` an explicit type [INFO] [stdout] | [INFO] [stdout] 20 | let client: /* Type */ = async_nats::connect(nats_url).await?; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> examples/json.rs:23:26 [INFO] [stdout] | [INFO] [stdout] 23 | let mut subscriber = client.subscribe("foo").await?.take(1); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/jwt_tests.rs:23:18 [INFO] [stdout] | [INFO] [stdout] 23 | let nc = async_nats::ConnectOptions::with_credentials_file( [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::ConnectOptions; [INFO] [stdout] | [INFO] [stdout] help: if you import `ConnectOptions`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 23 - let nc = async_nats::ConnectOptions::with_credentials_file( [INFO] [stdout] 23 + let nc = ConnectOptions::with_credentials_file( [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/jwt_tests.rs:43:18 [INFO] [stdout] | [INFO] [stdout] 43 | let nc = async_nats::ConnectOptions::new() [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::ConnectOptions; [INFO] [stdout] | [INFO] [stdout] help: if you import `ConnectOptions`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 43 - let nc = async_nats::ConnectOptions::new() [INFO] [stdout] 43 + let nc = ConnectOptions::new() [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/jwt_tests.rs:68:22 [INFO] [stdout] | [INFO] [stdout] 68 | let client = async_nats::ConnectOptions::with_credentials_file( [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::ConnectOptions; [INFO] [stdout] | [INFO] [stdout] help: if you import `ConnectOptions`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 68 - let client = async_nats::ConnectOptions::with_credentials_file( [INFO] [stdout] 68 + let client = ConnectOptions::with_credentials_file( [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/jwt_tests.rs:20:17 [INFO] [stdout] | [INFO] [stdout] 20 | let s = nats_server::run_server("tests/configs/jwt.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/nkey_tests.rs:23:18 [INFO] [stdout] | [INFO] [stdout] 23 | let nc = async_nats::ConnectOptions::with_nkey(SECRET_SEED.into()) [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::ConnectOptions; [INFO] [stdout] | [INFO] [stdout] help: if you import `ConnectOptions`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 23 - let nc = async_nats::ConnectOptions::with_nkey(SECRET_SEED.into()) [INFO] [stdout] 23 + let nc = ConnectOptions::with_nkey(SECRET_SEED.into()) [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/nkey_tests.rs:38:18 [INFO] [stdout] | [INFO] [stdout] 38 | let nc = async_nats::ConnectOptions::new() [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::ConnectOptions; [INFO] [stdout] | [INFO] [stdout] help: if you import `ConnectOptions`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 38 - let nc = async_nats::ConnectOptions::new() [INFO] [stdout] 38 + let nc = ConnectOptions::new() [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/nkey_tests.rs:60:22 [INFO] [stdout] | [INFO] [stdout] 60 | let client = async_nats::ConnectOptions::with_nkey(SECRET_SEED.into()) [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::ConnectOptions; [INFO] [stdout] | [INFO] [stdout] help: if you import `ConnectOptions`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 60 - let client = async_nats::ConnectOptions::with_nkey(SECRET_SEED.into()) [INFO] [stdout] 60 + let client = ConnectOptions::with_nkey(SECRET_SEED.into()) [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:23:18 [INFO] [stdout] | [INFO] [stdout] 23 | let nc = async_nats::ConnectOptions::with_credentials_file( [INFO] [stdout] | __________________^ [INFO] [stdout] 24 | | path.join("tests/configs/TestUser.creds"), [INFO] [stdout] 25 | | ) [INFO] [stdout] 26 | | .await [INFO] [stdout] | |______________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:23:18 [INFO] [stdout] | [INFO] [stdout] 23 | let nc = async_nats::ConnectOptions::with_credentials_file( [INFO] [stdout] | __________________^ [INFO] [stdout] 24 | | path.join("tests/configs/TestUser.creds"), [INFO] [stdout] 25 | | ) [INFO] [stdout] 26 | | .await [INFO] [stdout] 27 | | .expect("loaded user creds file") [INFO] [stdout] 28 | | .connect(s.client_url()) [INFO] [stdout] 29 | | .await [INFO] [stdout] | |______________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/nkey_tests.rs:21:17 [INFO] [stdout] | [INFO] [stdout] 21 | let s = nats_server::run_server("tests/configs/nkey.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:33:9 [INFO] [stdout] | [INFO] [stdout] 33 | / nc.publish("hello", "world".into()) [INFO] [stdout] 34 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/jwt_tests.rs:40:17 [INFO] [stdout] | [INFO] [stdout] 40 | let s = nats_server::run_server("tests/configs/jwt.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:43:18 [INFO] [stdout] | [INFO] [stdout] 43 | let nc = async_nats::ConnectOptions::new() [INFO] [stdout] | __________________^ [INFO] [stdout] 44 | | .credentials_file(path.join("tests/configs/TestUser.creds")) [INFO] [stdout] 45 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:43:18 [INFO] [stdout] | [INFO] [stdout] 43 | let nc = async_nats::ConnectOptions::new() [INFO] [stdout] | __________________^ [INFO] [stdout] 44 | | .credentials_file(path.join("tests/configs/TestUser.creds")) [INFO] [stdout] 45 | | .await [INFO] [stdout] 46 | | .expect("loaded user creds file") [INFO] [stdout] 47 | | .connect(s.client_url()) [INFO] [stdout] 48 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:52:9 [INFO] [stdout] | [INFO] [stdout] 52 | / nc.publish("hello", "world".into()) [INFO] [stdout] 53 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/nkey_tests.rs:23:18 [INFO] [stdout] | [INFO] [stdout] 23 | let nc = async_nats::ConnectOptions::with_nkey(SECRET_SEED.into()) [INFO] [stdout] | __________________^ [INFO] [stdout] 24 | | .connect(s.client_url()) [INFO] [stdout] 25 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/jwt_tests.rs:63:13 [INFO] [stdout] | [INFO] [stdout] 63 | nats_server::run_server("tests/configs/jwt.conf"), [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/nkey_tests.rs:29:9 [INFO] [stdout] | [INFO] [stdout] 29 | / nc.publish("hello", "world".into()) [INFO] [stdout] 30 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/jwt_tests.rs:64:13 [INFO] [stdout] | [INFO] [stdout] 64 | nats_server::run_server("tests/configs/jwt.conf"), [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/jwt_tests.rs:65:13 [INFO] [stdout] | [INFO] [stdout] 65 | nats_server::run_server("tests/configs/jwt.conf"), [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:68:22 [INFO] [stdout] | [INFO] [stdout] 68 | let client = async_nats::ConnectOptions::with_credentials_file( [INFO] [stdout] | ______________________^ [INFO] [stdout] 69 | | path.join("tests/configs/TestUser.creds"), [INFO] [stdout] 70 | | ) [INFO] [stdout] 71 | | .await [INFO] [stdout] | |______________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:76:23 [INFO] [stdout] | [INFO] [stdout] 76 | .map(|server| server.client_url().parse::().unwrap()) [INFO] [stdout] | ^^^^^^ ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this closure parameter an explicit type [INFO] [stdout] | [INFO] [stdout] 76 | .map(|server: /* Type */| server.client_url().parse::().unwrap()) [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:68:22 [INFO] [stdout] | [INFO] [stdout] 68 | let client = async_nats::ConnectOptions::with_credentials_file( [INFO] [stdout] | ______________________^ [INFO] [stdout] 69 | | path.join("tests/configs/TestUser.creds"), [INFO] [stdout] 70 | | ) [INFO] [stdout] 71 | | .await [INFO] [stdout] ... | [INFO] [stdout] 80 | | .await [INFO] [stdout] | |______________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:83:30 [INFO] [stdout] | [INFO] [stdout] 83 | let mut subscriber = client.subscribe("test").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:85:13 [INFO] [stdout] | [INFO] [stdout] 85 | client.publish("test", "data".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> examples/json.rs:15:31 [INFO] [stdout] | [INFO] [stdout] 15 | async fn main() -> Result<(), async_nats::Error> { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0282, E0433. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0282`. [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:86:13 [INFO] [stdout] | [INFO] [stdout] 86 | client.flush().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/jwt_tests.rs:87:21 [INFO] [stdout] | [INFO] [stdout] 87 | assert!(subscriber.next().await.is_some()); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/nkey_tests.rs:36:17 [INFO] [stdout] | [INFO] [stdout] 36 | let s = nats_server::run_server("tests/configs/nkey.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/nkey_tests.rs:38:18 [INFO] [stdout] | [INFO] [stdout] 38 | let nc = async_nats::ConnectOptions::new() [INFO] [stdout] | __________________^ [INFO] [stdout] 39 | | .nkey(SECRET_SEED.into()) [INFO] [stdout] 40 | | .connect(s.client_url()) [INFO] [stdout] 41 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/nkey_tests.rs:45:9 [INFO] [stdout] | [INFO] [stdout] 45 | / nc.publish("hello", "world".into()) [INFO] [stdout] 46 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/nkey_tests.rs:55:13 [INFO] [stdout] | [INFO] [stdout] 55 | nats_server::run_server("tests/configs/nkey.conf"), [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/nkey_tests.rs:56:13 [INFO] [stdout] | [INFO] [stdout] 56 | nats_server::run_server("tests/configs/nkey.conf"), [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/nkey_tests.rs:57:13 [INFO] [stdout] | [INFO] [stdout] 57 | nats_server::run_server("tests/configs/nkey.conf"), [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/nkey_tests.rs:64:27 [INFO] [stdout] | [INFO] [stdout] 64 | .map(|server| server.client_url().parse::().unwrap()) [INFO] [stdout] | ^^^^^^ ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this closure parameter an explicit type [INFO] [stdout] | [INFO] [stdout] 64 | .map(|server: /* Type */| server.client_url().parse::().unwrap()) [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/nkey_tests.rs:60:22 [INFO] [stdout] | [INFO] [stdout] 60 | let client = async_nats::ConnectOptions::with_nkey(SECRET_SEED.into()) [INFO] [stdout] | ______________________^ [INFO] [stdout] 61 | | .connect( [INFO] [stdout] 62 | | servers [INFO] [stdout] 63 | | .iter() [INFO] [stdout] ... | [INFO] [stdout] 68 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/nkey_tests.rs:71:30 [INFO] [stdout] | [INFO] [stdout] 71 | let mut subscriber = client.subscribe("test").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/nkey_tests.rs:73:13 [INFO] [stdout] | [INFO] [stdout] 73 | client.publish("test", "data".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/nkey_tests.rs:74:13 [INFO] [stdout] | [INFO] [stdout] 74 | client.flush().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/nkey_tests.rs:75:21 [INFO] [stdout] | [INFO] [stdout] 75 | assert!(subscriber.next().await.is_some()); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0282, E0432, E0433. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0282`. [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0282, E0432, E0433. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0282`. [INFO] [stdout] [INFO] [stderr] error: could not compile `async-nats-wrpc` (example "json") due to 4 previous errors [INFO] [stderr] error: could not compile `async-nats-wrpc` (test "nkey_tests") due to 19 previous errors [INFO] [stderr] error: could not compile `async-nats-wrpc` (test "jwt_tests") due to 22 previous errors [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:33:25 [INFO] [stdout] | [INFO] [stdout] 33 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 33 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 33 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:36:34 [INFO] [stdout] | [INFO] [stdout] 36 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 36 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 36 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:109:25 [INFO] [stdout] | [INFO] [stdout] 109 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 109 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 109 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:112:34 [INFO] [stdout] | [INFO] [stdout] 112 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 112 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 112 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:150:25 [INFO] [stdout] | [INFO] [stdout] 150 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 150 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 150 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:153:34 [INFO] [stdout] | [INFO] [stdout] 153 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 153 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 153 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:210:25 [INFO] [stdout] | [INFO] [stdout] 210 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 210 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 210 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:213:34 [INFO] [stdout] | [INFO] [stdout] 213 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 213 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 213 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:248:25 [INFO] [stdout] | [INFO] [stdout] 248 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 248 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 248 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:251:34 [INFO] [stdout] | [INFO] [stdout] 251 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 251 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 251 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:281:25 [INFO] [stdout] | [INFO] [stdout] 281 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 281 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 281 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:284:34 [INFO] [stdout] | [INFO] [stdout] 284 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 284 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 284 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:315:25 [INFO] [stdout] | [INFO] [stdout] 315 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 315 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 315 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:318:34 [INFO] [stdout] | [INFO] [stdout] 318 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 318 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 318 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:363:25 [INFO] [stdout] | [INFO] [stdout] 363 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 363 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 363 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:366:34 [INFO] [stdout] | [INFO] [stdout] 366 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 366 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 366 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:408:25 [INFO] [stdout] | [INFO] [stdout] 408 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 408 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 408 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:411:34 [INFO] [stdout] | [INFO] [stdout] 411 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 411 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 411 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:444:25 [INFO] [stdout] | [INFO] [stdout] 444 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 444 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 444 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:447:34 [INFO] [stdout] | [INFO] [stdout] 447 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 447 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 447 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:499:25 [INFO] [stdout] | [INFO] [stdout] 499 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 499 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 499 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:502:34 [INFO] [stdout] | [INFO] [stdout] 502 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 502 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 502 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:567:25 [INFO] [stdout] | [INFO] [stdout] 567 | let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 567 - let jetstream = async_nats::jetstream::new(client); [INFO] [stdout] 567 + let jetstream = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:570:34 [INFO] [stdout] | [INFO] [stdout] 570 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 570 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 570 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:577:34 [INFO] [stdout] | [INFO] [stdout] 577 | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::object_store; [INFO] [stdout] | [INFO] [stdout] help: if you import `object_store`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 577 - .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 577 + .create_object_store(object_store::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:30:22 [INFO] [stdout] | [INFO] [stdout] 30 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:31:22 [INFO] [stdout] | [INFO] [stdout] 31 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:31:22 [INFO] [stdout] | [INFO] [stdout] 31 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:35:22 [INFO] [stdout] | [INFO] [stdout] 35 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 36 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 37 | | bucket: "bucket".to_string(), [INFO] [stdout] 38 | | ..Default::default() [INFO] [stdout] 39 | | }) [INFO] [stdout] 40 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:49:9 [INFO] [stdout] | [INFO] [stdout] 49 | bucket.put("FOO", &mut bytes.as_slice()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:51:26 [INFO] [stdout] | [INFO] [stdout] 51 | let mut object = bucket.get("FOO").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:75:9 [INFO] [stdout] | [INFO] [stdout] 75 | bucket.add_link("link", &object.info).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:78:31 [INFO] [stdout] | [INFO] [stdout] 78 | let mut object_link = bucket.get("link").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:82:9 [INFO] [stdout] | [INFO] [stdout] 82 | object_link.read_to_end(&mut contents).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:85:9 [INFO] [stdout] | [INFO] [stdout] 85 | / bucket [INFO] [stdout] 86 | | .put( [INFO] [stdout] 87 | | ObjectMetadata { [INFO] [stdout] 88 | | name: "BAR".to_string(), [INFO] [stdout] ... | [INFO] [stdout] 94 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:97:20 [INFO] [stdout] | [INFO] [stdout] 97 | let meta = bucket.get("BAR").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:106:22 [INFO] [stdout] | [INFO] [stdout] 106 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:107:22 [INFO] [stdout] | [INFO] [stdout] 107 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:107:22 [INFO] [stdout] | [INFO] [stdout] 107 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:111:22 [INFO] [stdout] | [INFO] [stdout] 111 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 112 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 113 | | bucket: "bucket".to_string(), [INFO] [stdout] 114 | | ..Default::default() [INFO] [stdout] 115 | | }) [INFO] [stdout] 116 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:119:9 [INFO] [stdout] | [INFO] [stdout] 119 | / bucket [INFO] [stdout] 120 | | .put("FOO", &mut std::io::Cursor::new(vec![1, 2, 3, 4])) [INFO] [stdout] 121 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:124:27 [INFO] [stdout] | [INFO] [stdout] 124 | let mut watcher = bucket.watch().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:130:17 [INFO] [stdout] | [INFO] [stdout] 130 | / bucket [INFO] [stdout] 131 | | .put("BAR", &mut io::Cursor::new(vec![2, 3, 4, 5])) [INFO] [stdout] 132 | | .await [INFO] [stdout] | |__________________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:134:17 [INFO] [stdout] | [INFO] [stdout] 134 | bucket.delete("BAR").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:138:22 [INFO] [stdout] | [INFO] [stdout] 138 | let object = watcher.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:140:22 [INFO] [stdout] | [INFO] [stdout] 140 | let object = watcher.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:147:22 [INFO] [stdout] | [INFO] [stdout] 147 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:148:22 [INFO] [stdout] | [INFO] [stdout] 148 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:148:22 [INFO] [stdout] | [INFO] [stdout] 148 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:152:22 [INFO] [stdout] | [INFO] [stdout] 152 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 153 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 154 | | bucket: "bucket".to_string(), [INFO] [stdout] 155 | | ..Default::default() [INFO] [stdout] 156 | | }) [INFO] [stdout] 157 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:160:9 [INFO] [stdout] | [INFO] [stdout] 160 | / bucket [INFO] [stdout] 161 | | .put("FOO", &mut std::io::Cursor::new(vec![1, 2, 3, 4])) [INFO] [stdout] 162 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:165:9 [INFO] [stdout] | [INFO] [stdout] 165 | / bucket [INFO] [stdout] 166 | | .put("BAR", &mut std::io::Cursor::new(vec![5, 6, 7, 8])) [INFO] [stdout] 167 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:170:9 [INFO] [stdout] | [INFO] [stdout] 170 | / bucket [INFO] [stdout] 171 | | .put("FOO", &mut std::io::Cursor::new(vec![9, 0, 1, 2])) [INFO] [stdout] 172 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:175:27 [INFO] [stdout] | [INFO] [stdout] 175 | let mut watcher = bucket.watch_with_history().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:181:17 [INFO] [stdout] | [INFO] [stdout] 181 | / bucket [INFO] [stdout] 182 | | .put("BAR", &mut io::Cursor::new(vec![2, 3, 4, 5])) [INFO] [stdout] 183 | | .await [INFO] [stdout] | |__________________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:185:17 [INFO] [stdout] | [INFO] [stdout] 185 | bucket.delete("BAR").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:191:22 [INFO] [stdout] | [INFO] [stdout] 191 | let object = watcher.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:194:22 [INFO] [stdout] | [INFO] [stdout] 194 | let object = watcher.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:198:22 [INFO] [stdout] | [INFO] [stdout] 198 | let object = watcher.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:200:22 [INFO] [stdout] | [INFO] [stdout] 200 | let object = watcher.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:207:22 [INFO] [stdout] | [INFO] [stdout] 207 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:208:22 [INFO] [stdout] | [INFO] [stdout] 208 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:208:22 [INFO] [stdout] | [INFO] [stdout] 208 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:212:22 [INFO] [stdout] | [INFO] [stdout] 212 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 213 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 214 | | bucket: "bucket".to_string(), [INFO] [stdout] 215 | | ..Default::default() [INFO] [stdout] 216 | | }) [INFO] [stdout] 217 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:220:9 [INFO] [stdout] | [INFO] [stdout] 220 | / bucket [INFO] [stdout] 221 | | .put("FOO", &mut io::Cursor::new(vec![2, 3, 4, 5])) [INFO] [stdout] 222 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:225:20 [INFO] [stdout] | [INFO] [stdout] 225 | let info = bucket.info("FOO").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:234:9 [INFO] [stdout] | [INFO] [stdout] 234 | / bucket [INFO] [stdout] 235 | | .put("FOO", &mut io::Cursor::new(vec![2, 3, 4, 5])) [INFO] [stdout] 236 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:239:20 [INFO] [stdout] | [INFO] [stdout] 239 | let info = bucket.info("FOO").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:245:22 [INFO] [stdout] | [INFO] [stdout] 245 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:246:22 [INFO] [stdout] | [INFO] [stdout] 246 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:246:22 [INFO] [stdout] | [INFO] [stdout] 246 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:250:22 [INFO] [stdout] | [INFO] [stdout] 250 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 251 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 252 | | bucket: "bucket".to_string(), [INFO] [stdout] 253 | | ..Default::default() [INFO] [stdout] 254 | | }) [INFO] [stdout] 255 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:262:9 [INFO] [stdout] | [INFO] [stdout] 262 | bucket.put("FOO", &mut bytes.as_slice()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:264:20 [INFO] [stdout] | [INFO] [stdout] 264 | let info = bucket.info("FOO").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:269:9 [INFO] [stdout] | [INFO] [stdout] 269 | bucket.delete("FOO").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:271:20 [INFO] [stdout] | [INFO] [stdout] 271 | let info = bucket.info("FOO").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:278:22 [INFO] [stdout] | [INFO] [stdout] 278 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:279:22 [INFO] [stdout] | [INFO] [stdout] 279 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:279:22 [INFO] [stdout] | [INFO] [stdout] 279 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:283:26 [INFO] [stdout] | [INFO] [stdout] 283 | let mut bucket = jetstream [INFO] [stdout] | __________________________^ [INFO] [stdout] 284 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 285 | | bucket: "bucket".to_string(), [INFO] [stdout] 286 | | ..Default::default() [INFO] [stdout] 287 | | }) [INFO] [stdout] 288 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:295:9 [INFO] [stdout] | [INFO] [stdout] 295 | bucket.put("FOO", &mut bytes.as_slice()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:297:20 [INFO] [stdout] | [INFO] [stdout] 297 | let info = bucket.info("FOO").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:302:9 [INFO] [stdout] | [INFO] [stdout] 302 | bucket.seal().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:304:26 [INFO] [stdout] | [INFO] [stdout] 304 | let mut stream = jetstream.get_stream("OBJ_bucket").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:305:20 [INFO] [stdout] | [INFO] [stdout] 305 | let info = stream.info().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:312:22 [INFO] [stdout] | [INFO] [stdout] 312 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:313:22 [INFO] [stdout] | [INFO] [stdout] 313 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:313:22 [INFO] [stdout] | [INFO] [stdout] 313 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:317:22 [INFO] [stdout] | [INFO] [stdout] 317 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 318 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 319 | | bucket: "bucket".to_string(), [INFO] [stdout] 320 | | ..Default::default() [INFO] [stdout] 321 | | }) [INFO] [stdout] 322 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:347:13 [INFO] [stdout] | [INFO] [stdout] 347 | bucket.put(filename, &mut file.as_slice()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:349:30 [INFO] [stdout] | [INFO] [stdout] 349 | let mut object = bucket.get(filename).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:353:13 [INFO] [stdout] | [INFO] [stdout] 353 | object.read_to_end(&mut result).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:360:22 [INFO] [stdout] | [INFO] [stdout] 360 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:361:22 [INFO] [stdout] | [INFO] [stdout] 361 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:361:22 [INFO] [stdout] | [INFO] [stdout] 361 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:365:22 [INFO] [stdout] | [INFO] [stdout] 365 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 366 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 367 | | bucket: "bucket".to_string(), [INFO] [stdout] 368 | | ..Default::default() [INFO] [stdout] 369 | | }) [INFO] [stdout] 370 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:372:9 [INFO] [stdout] | [INFO] [stdout] 372 | / bucket [INFO] [stdout] 373 | | .put( [INFO] [stdout] 374 | | ObjectMetadata { [INFO] [stdout] 375 | | name: "Foo".to_string(), [INFO] [stdout] ... | [INFO] [stdout] 381 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:383:9 [INFO] [stdout] | [INFO] [stdout] 383 | / bucket [INFO] [stdout] 384 | | .put("DEL", &mut "32142421424".as_bytes()) [INFO] [stdout] 385 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:387:9 [INFO] [stdout] | [INFO] [stdout] 387 | bucket.delete("DEL").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:389:13 [INFO] [stdout] | [INFO] [stdout] 389 | / bucket [INFO] [stdout] 390 | | .put(format!("{i}").as_ref(), &mut "blalbalballba".as_bytes()) [INFO] [stdout] 391 | | .await [INFO] [stdout] | |______________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:394:24 [INFO] [stdout] | [INFO] [stdout] 394 | let mut list = bucket.list().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:395:19 [INFO] [stdout] | [INFO] [stdout] 395 | let obj = list.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:398:20 [INFO] [stdout] | [INFO] [stdout] 398 | assert_eq!(list.next().await.unwrap().unwrap().name, "0"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:399:20 [INFO] [stdout] | [INFO] [stdout] 399 | assert_eq!(list.next().await.unwrap().unwrap().name, "1"); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:405:22 [INFO] [stdout] | [INFO] [stdout] 405 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:406:22 [INFO] [stdout] | [INFO] [stdout] 406 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:406:22 [INFO] [stdout] | [INFO] [stdout] 406 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:410:22 [INFO] [stdout] | [INFO] [stdout] 410 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 411 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 412 | | bucket: "bucket".to_string(), [INFO] [stdout] 413 | | ..Default::default() [INFO] [stdout] 414 | | }) [INFO] [stdout] 415 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:417:9 [INFO] [stdout] | [INFO] [stdout] 417 | / bucket [INFO] [stdout] 418 | | .put("DATA", &mut "some data".as_bytes()) [INFO] [stdout] 419 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:421:9 [INFO] [stdout] | [INFO] [stdout] 421 | / bucket [INFO] [stdout] 422 | | .put("DATA", &mut "some data".as_bytes()) [INFO] [stdout] 423 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:425:9 [INFO] [stdout] | [INFO] [stdout] 425 | / bucket [INFO] [stdout] 426 | | .put("DATA", &mut "some data".as_bytes()) [INFO] [stdout] 427 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:429:9 [INFO] [stdout] | [INFO] [stdout] 429 | / bucket [INFO] [stdout] 430 | | .put("DATA", &mut "some data".as_bytes()) [INFO] [stdout] 431 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:433:9 [INFO] [stdout] | [INFO] [stdout] 433 | / bucket [INFO] [stdout] 434 | | .put("DATA", &mut "some data".as_bytes()) [INFO] [stdout] 435 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:441:22 [INFO] [stdout] | [INFO] [stdout] 441 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:442:22 [INFO] [stdout] | [INFO] [stdout] 442 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:442:22 [INFO] [stdout] | [INFO] [stdout] 442 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:446:22 [INFO] [stdout] | [INFO] [stdout] 446 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 447 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 448 | | bucket: "bucket".to_string(), [INFO] [stdout] 449 | | ..Default::default() [INFO] [stdout] 450 | | }) [INFO] [stdout] 451 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:453:9 [INFO] [stdout] | [INFO] [stdout] 453 | / bucket [INFO] [stdout] 454 | | .put("old_object", &mut "some data".as_bytes()) [INFO] [stdout] 455 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:463:9 [INFO] [stdout] | [INFO] [stdout] 463 | / bucket [INFO] [stdout] 464 | | .update_metadata("old_object", given_metadata.clone()) [INFO] [stdout] 465 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:468:22 [INFO] [stdout] | [INFO] [stdout] 468 | let stream = jetstream.get_stream("OBJ_bucket").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:470:9 [INFO] [stdout] | [INFO] [stdout] 470 | / stream [INFO] [stdout] 471 | | .direct_get_last_for_subject(format!( [INFO] [stdout] 472 | | "$O.bucket.M.{}", [INFO] [stdout] 473 | | base64::engine::general_purpose::URL_SAFE.encode("new_object") [INFO] [stdout] 474 | | )) [INFO] [stdout] 475 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:478:32 [INFO] [stdout] | [INFO] [stdout] 478 | let old_meta_subject = stream [INFO] [stdout] | ________________________________^ [INFO] [stdout] 479 | | .direct_get_last_for_subject(format!( [INFO] [stdout] 480 | | "$O.bucket.M.{}", [INFO] [stdout] 481 | | base64::engine::general_purpose::URL_SAFE.encode("old_object") [INFO] [stdout] 482 | | )) [INFO] [stdout] 483 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:488:20 [INFO] [stdout] | [INFO] [stdout] 488 | let info = bucket.info("new_object").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:496:22 [INFO] [stdout] | [INFO] [stdout] 496 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:497:22 [INFO] [stdout] | [INFO] [stdout] 497 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:497:22 [INFO] [stdout] | [INFO] [stdout] 497 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:501:22 [INFO] [stdout] | [INFO] [stdout] 501 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 502 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 503 | | bucket: "bucket".to_string(), [INFO] [stdout] 504 | | ..Default::default() [INFO] [stdout] 505 | | }) [INFO] [stdout] 506 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:508:22 [INFO] [stdout] | [INFO] [stdout] 508 | let object = bucket [INFO] [stdout] | ______________________^ [INFO] [stdout] 509 | | .put("object", &mut "some data".as_bytes()) [INFO] [stdout] 510 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:513:30 [INFO] [stdout] | [INFO] [stdout] 513 | let another_object = bucket [INFO] [stdout] | ______________________________^ [INFO] [stdout] 514 | | .put("another_object", &mut "other data".as_bytes()) [INFO] [stdout] 515 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:518:9 [INFO] [stdout] | [INFO] [stdout] 518 | bucket.add_link("link", &object).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:520:25 [INFO] [stdout] | [INFO] [stdout] 520 | let link_info = bucket.info("link").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:549:22 [INFO] [stdout] | [INFO] [stdout] 549 | let result = bucket [INFO] [stdout] | ______________________^ [INFO] [stdout] 550 | | .add_link("object", &another_object) [INFO] [stdout] 551 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:555:22 [INFO] [stdout] | [INFO] [stdout] 555 | let result = bucket.add_link("", &another_object).await.unwrap_err(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:558:22 [INFO] [stdout] | [INFO] [stdout] 558 | let result = bucket.add_link("new_link", &link_info).await.unwrap_err(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/object_store.rs:564:22 [INFO] [stdout] | [INFO] [stdout] 564 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/object_store.rs:565:22 [INFO] [stdout] | [INFO] [stdout] 565 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:565:22 [INFO] [stdout] | [INFO] [stdout] 565 | let client = async_nats::connect(server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:569:9 [INFO] [stdout] | [INFO] [stdout] 569 | / jetstream [INFO] [stdout] 570 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 571 | | bucket: "another".to_string(), [INFO] [stdout] 572 | | ..Default::default() [INFO] [stdout] 573 | | }) [INFO] [stdout] 574 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:576:22 [INFO] [stdout] | [INFO] [stdout] 576 | let bucket = jetstream [INFO] [stdout] | ______________________^ [INFO] [stdout] 577 | | .create_object_store(async_nats::jetstream::object_store::Config { [INFO] [stdout] 578 | | bucket: "bucket".to_string(), [INFO] [stdout] 579 | | ..Default::default() [INFO] [stdout] 580 | | }) [INFO] [stdout] 581 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:584:9 [INFO] [stdout] | [INFO] [stdout] 584 | bucket.add_bucket_link("link", "another").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/object_store.rs:586:25 [INFO] [stdout] | [INFO] [stdout] 586 | let link_info = bucket.info("link").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0282, E0433. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0282`. [INFO] [stdout] [INFO] [stderr] error: could not compile `async-nats-wrpc` (test "object_store") due to 142 previous errors [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:36:23 [INFO] [stdout] | [INFO] [stdout] 36 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 36 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 36 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:39:31 [INFO] [stdout] | [INFO] [stdout] 39 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 39 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 39 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:64:23 [INFO] [stdout] | [INFO] [stdout] 64 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 64 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 64 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:67:31 [INFO] [stdout] | [INFO] [stdout] 67 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 67 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 67 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:103:23 [INFO] [stdout] | [INFO] [stdout] 103 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 103 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 103 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:106:31 [INFO] [stdout] | [INFO] [stdout] 106 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 106 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 106 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:135:23 [INFO] [stdout] | [INFO] [stdout] 135 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 135 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 135 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:138:31 [INFO] [stdout] | [INFO] [stdout] 138 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 138 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 138 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:169:23 [INFO] [stdout] | [INFO] [stdout] 169 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 169 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 169 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:172:31 [INFO] [stdout] | [INFO] [stdout] 172 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 172 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 172 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:194:28 [INFO] [stdout] | [INFO] [stdout] 194 | .update_stream(async_nats::jetstream::stream::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::stream; [INFO] [stdout] | [INFO] [stdout] help: if you import `stream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 194 - .update_stream(async_nats::jetstream::stream::Config { [INFO] [stdout] 194 + .update_stream(stream::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:222:23 [INFO] [stdout] | [INFO] [stdout] 222 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 222 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 222 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:225:31 [INFO] [stdout] | [INFO] [stdout] 225 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 225 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 225 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:258:23 [INFO] [stdout] | [INFO] [stdout] 258 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 258 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 258 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:261:31 [INFO] [stdout] | [INFO] [stdout] 261 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 261 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 261 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:297:23 [INFO] [stdout] | [INFO] [stdout] 297 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 297 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 297 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:300:31 [INFO] [stdout] | [INFO] [stdout] 300 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 300 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 300 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:346:23 [INFO] [stdout] | [INFO] [stdout] 346 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 346 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 346 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:349:31 [INFO] [stdout] | [INFO] [stdout] 349 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 349 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 349 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:386:23 [INFO] [stdout] | [INFO] [stdout] 386 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 386 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 386 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:389:31 [INFO] [stdout] | [INFO] [stdout] 389 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 389 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 389 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:436:23 [INFO] [stdout] | [INFO] [stdout] 436 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 436 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 436 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:439:31 [INFO] [stdout] | [INFO] [stdout] 439 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 439 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 439 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:474:23 [INFO] [stdout] | [INFO] [stdout] 474 | let context = async_nats::jetstream::new(client.clone()); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 474 - let context = async_nats::jetstream::new(client.clone()); [INFO] [stdout] 474 + let context = jetstream::new(client.clone()); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:477:31 [INFO] [stdout] | [INFO] [stdout] 477 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 477 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 477 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:534:23 [INFO] [stdout] | [INFO] [stdout] 534 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 534 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 534 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:537:31 [INFO] [stdout] | [INFO] [stdout] 537 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 537 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 537 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:593:23 [INFO] [stdout] | [INFO] [stdout] 593 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 593 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 593 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:596:31 [INFO] [stdout] | [INFO] [stdout] 596 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 596 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 596 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:668:23 [INFO] [stdout] | [INFO] [stdout] 668 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 668 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 668 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:671:31 [INFO] [stdout] | [INFO] [stdout] 671 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 671 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 671 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:721:23 [INFO] [stdout] | [INFO] [stdout] 721 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 721 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 721 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:724:31 [INFO] [stdout] | [INFO] [stdout] 724 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 724 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 724 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:767:23 [INFO] [stdout] | [INFO] [stdout] 767 | let context = async_nats::jetstream::new(client); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 767 - let context = async_nats::jetstream::new(client); [INFO] [stdout] 767 + let context = jetstream::new(client); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:770:31 [INFO] [stdout] | [INFO] [stdout] 770 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 770 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 770 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:824:31 [INFO] [stdout] | [INFO] [stdout] 824 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 824 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 824 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:864:23 [INFO] [stdout] | [INFO] [stdout] 864 | let context = async_nats::jetstream::new(client.clone()); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 864 - let context = async_nats::jetstream::new(client.clone()); [INFO] [stdout] 864 + let context = jetstream::new(client.clone()); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:867:31 [INFO] [stdout] | [INFO] [stdout] 867 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 867 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 867 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:899:22 [INFO] [stdout] | [INFO] [stdout] 899 | let hub_js = async_nats::jetstream::new(hub); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 899 - let hub_js = async_nats::jetstream::new(hub); [INFO] [stdout] 899 + let hub_js = jetstream::new(hub); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:902:31 [INFO] [stdout] | [INFO] [stdout] 902 | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 902 - .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 902 + .create_key_value(kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:911:29 [INFO] [stdout] | [INFO] [stdout] 911 | let mirror_bucket = async_nats::jetstream::kv::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::kv; [INFO] [stdout] | [INFO] [stdout] help: if you import `kv`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 911 - let mirror_bucket = async_nats::jetstream::kv::Config { [INFO] [stdout] 911 + let mirror_bucket = kv::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:920:23 [INFO] [stdout] | [INFO] [stdout] 920 | let leaf_js = async_nats::jetstream::new(leaf.clone()); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 920 - let leaf_js = async_nats::jetstream::new(leaf.clone()); [INFO] [stdout] 920 + let leaf_js = jetstream::new(leaf.clone()); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:950:27 [INFO] [stdout] | [INFO] [stdout] 950 | let leaf_hub_js = async_nats::jetstream::with_domain(leaf, "HUB"); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 950 - let leaf_hub_js = async_nats::jetstream::with_domain(leaf, "HUB"); [INFO] [stdout] 950 + let leaf_hub_js = jetstream::with_domain(leaf, "HUB"); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:977:23 [INFO] [stdout] | [INFO] [stdout] 977 | let context = async_nats::jetstream::new(client.clone()); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream; [INFO] [stdout] | [INFO] [stdout] help: if you import `jetstream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 977 - let context = async_nats::jetstream::new(client.clone()); [INFO] [stdout] 977 + let context = jetstream::new(client.clone()); [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:980:28 [INFO] [stdout] | [INFO] [stdout] 980 | .create_stream(async_nats::jetstream::stream::Config { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::stream; [INFO] [stdout] | [INFO] [stdout] help: if you import `stream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 980 - .create_stream(async_nats::jetstream::stream::Config { [INFO] [stdout] 980 + .create_stream(stream::Config { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:983:33 [INFO] [stdout] | [INFO] [stdout] 983 | republish: Some(async_nats::jetstream::stream::Republish { [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] help: consider importing this module [INFO] [stdout] | [INFO] [stdout] 15 + use async_nats_wrpc::jetstream::stream; [INFO] [stdout] | [INFO] [stdout] help: if you import `stream`, refer to it directly [INFO] [stdout] | [INFO] [stdout] 983 - republish: Some(async_nats::jetstream::stream::Republish { [INFO] [stdout] 983 + republish: Some(stream::Republish { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:29:22 [INFO] [stdout] | [INFO] [stdout] 29 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:30:22 [INFO] [stdout] | [INFO] [stdout] 30 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 31 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 32 | | .connect(server.client_url()) [INFO] [stdout] 33 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:38:22 [INFO] [stdout] | [INFO] [stdout] 38 | let mut kv = context [INFO] [stdout] | ______________________^ [INFO] [stdout] 39 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 40 | | bucket: "test".into(), [INFO] [stdout] 41 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 46 | | }) [INFO] [stdout] 47 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:49:20 [INFO] [stdout] | [INFO] [stdout] 49 | let info = kv.stream.info().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:57:22 [INFO] [stdout] | [INFO] [stdout] 57 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:58:22 [INFO] [stdout] | [INFO] [stdout] 58 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 59 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 60 | | .connect(server.client_url()) [INFO] [stdout] 61 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:66:18 [INFO] [stdout] | [INFO] [stdout] 66 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 67 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 68 | | bucket: "test".into(), [INFO] [stdout] 69 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 74 | | }) [INFO] [stdout] 75 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:79:13 [INFO] [stdout] | [INFO] [stdout] 79 | let create = kv.create("key", payload.clone()).await; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 80 | assert!(create.is_ok()); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `create` an explicit type [INFO] [stdout] | [INFO] [stdout] 79 | let create: /* Type */ = kv.create("key", payload.clone()).await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:82:13 [INFO] [stdout] | [INFO] [stdout] 82 | let create = kv.create("key", payload.clone()).await; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 83 | assert!(create.is_err()); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `create` an explicit type [INFO] [stdout] | [INFO] [stdout] 82 | let create: /* Type */ = kv.create("key", payload.clone()).await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:85:9 [INFO] [stdout] | [INFO] [stdout] 85 | kv.delete("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:86:13 [INFO] [stdout] | [INFO] [stdout] 86 | let create = kv.create("key", payload.clone()).await; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 87 | assert!(create.is_ok()); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `create` an explicit type [INFO] [stdout] | [INFO] [stdout] 86 | let create: /* Type */ = kv.create("key", payload.clone()).await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:89:9 [INFO] [stdout] | [INFO] [stdout] 89 | kv.purge("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:90:13 [INFO] [stdout] | [INFO] [stdout] 90 | let create = kv.create("key", payload.clone()).await; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 91 | assert!(create.is_ok()); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `create` an explicit type [INFO] [stdout] | [INFO] [stdout] 90 | let create: /* Type */ = kv.create("key", payload.clone()).await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:96:22 [INFO] [stdout] | [INFO] [stdout] 96 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:97:22 [INFO] [stdout] | [INFO] [stdout] 97 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 98 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 99 | | .connect(server.client_url()) [INFO] [stdout] 100 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:105:18 [INFO] [stdout] | [INFO] [stdout] 105 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 106 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 107 | | bucket: "test".into(), [INFO] [stdout] 108 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 113 | | }) [INFO] [stdout] 114 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:117:9 [INFO] [stdout] | [INFO] [stdout] 117 | kv.put("key", payload.clone()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:118:21 [INFO] [stdout] | [INFO] [stdout] 118 | let value = kv.get("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:121:9 [INFO] [stdout] | [INFO] [stdout] 121 | kv.put("key", payload.clone()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:122:21 [INFO] [stdout] | [INFO] [stdout] 122 | let value = kv.get("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:128:22 [INFO] [stdout] | [INFO] [stdout] 128 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:129:22 [INFO] [stdout] | [INFO] [stdout] 129 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 130 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 131 | | .connect(server.client_url()) [INFO] [stdout] 132 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:137:18 [INFO] [stdout] | [INFO] [stdout] 137 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 138 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 139 | | bucket: "test".into(), [INFO] [stdout] 140 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 145 | | }) [INFO] [stdout] 146 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:149:9 [INFO] [stdout] | [INFO] [stdout] 149 | kv.put("key", payload.clone()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:150:21 [INFO] [stdout] | [INFO] [stdout] 150 | let value = kv.get("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:153:9 [INFO] [stdout] | [INFO] [stdout] 153 | kv.put("key", payload.clone()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:154:21 [INFO] [stdout] | [INFO] [stdout] 154 | let value = kv.get("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:156:23 [INFO] [stdout] | [INFO] [stdout] 156 | let nothing = kv.get("nothing").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:162:22 [INFO] [stdout] | [INFO] [stdout] 162 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:163:22 [INFO] [stdout] | [INFO] [stdout] 163 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 164 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 165 | | .connect(server.client_url()) [INFO] [stdout] 166 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:171:22 [INFO] [stdout] | [INFO] [stdout] 171 | let mut kv = context [INFO] [stdout] | ______________________^ [INFO] [stdout] 172 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 173 | | bucket: "test".into(), [INFO] [stdout] 174 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 179 | | }) [INFO] [stdout] 180 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:183:9 [INFO] [stdout] | [INFO] [stdout] 183 | kv.put("key", payload.clone()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:184:21 [INFO] [stdout] | [INFO] [stdout] 184 | let value = kv.get("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:187:9 [INFO] [stdout] | [INFO] [stdout] 187 | kv.put("key", payload.clone()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:188:21 [INFO] [stdout] | [INFO] [stdout] 188 | let value = kv.entry("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:190:23 [INFO] [stdout] | [INFO] [stdout] 190 | let nothing = kv.get("nothing").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:193:9 [INFO] [stdout] | [INFO] [stdout] 193 | / context [INFO] [stdout] 194 | | .update_stream(async_nats::jetstream::stream::Config { [INFO] [stdout] 195 | | max_messages_per_subject: 10, [INFO] [stdout] 196 | | name: "KV_test".into(), [INFO] [stdout] ... | [INFO] [stdout] 200 | | }) [INFO] [stdout] 201 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:204:20 [INFO] [stdout] | [INFO] [stdout] 204 | let info = kv.stream.info().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:207:23 [INFO] [stdout] | [INFO] [stdout] 207 | let nothing = kv.get("nothing").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:209:21 [INFO] [stdout] | [INFO] [stdout] 209 | let value = kv.entry("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:215:22 [INFO] [stdout] | [INFO] [stdout] 215 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:216:22 [INFO] [stdout] | [INFO] [stdout] 216 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 217 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 218 | | .connect(server.client_url()) [INFO] [stdout] 219 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:224:18 [INFO] [stdout] | [INFO] [stdout] 224 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 225 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 226 | | bucket: "test".into(), [INFO] [stdout] 227 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 232 | | }) [INFO] [stdout] 233 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:236:19 [INFO] [stdout] | [INFO] [stdout] 236 | let rev = kv.put("key", payload.clone()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:237:21 [INFO] [stdout] | [INFO] [stdout] 237 | let value = kv.get("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:240:20 [INFO] [stdout] | [INFO] [stdout] 240 | let rev2 = kv [INFO] [stdout] | ____________________^ [INFO] [stdout] 241 | | .update("key", updated_payload.clone(), rev) [INFO] [stdout] 242 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:244:21 [INFO] [stdout] | [INFO] [stdout] 244 | let value = kv.get("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:251:22 [INFO] [stdout] | [INFO] [stdout] 251 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:252:22 [INFO] [stdout] | [INFO] [stdout] 252 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 253 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 254 | | .connect(server.client_url()) [INFO] [stdout] 255 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:260:18 [INFO] [stdout] | [INFO] [stdout] 260 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 261 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 262 | | bucket: "delete".into(), [INFO] [stdout] 263 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 268 | | }) [INFO] [stdout] 269 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:272:9 [INFO] [stdout] | [INFO] [stdout] 272 | kv.put("key", payload.clone()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:273:21 [INFO] [stdout] | [INFO] [stdout] 273 | let value = kv.get("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:275:9 [INFO] [stdout] | [INFO] [stdout] 275 | kv.delete("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:276:18 [INFO] [stdout] | [INFO] [stdout] 276 | let ss = kv.get("kv").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:279:27 [INFO] [stdout] | [INFO] [stdout] 279 | let mut entries = kv.history("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:281:13 [INFO] [stdout] | [INFO] [stdout] 281 | let first_op = entries.next().await; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 282 | assert_eq!(first_op.unwrap().unwrap().operation, Operation::Put); [INFO] [stdout] | -------- type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `first_op` an explicit type [INFO] [stdout] | [INFO] [stdout] 281 | let first_op: /* Type */ = entries.next().await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:284:13 [INFO] [stdout] | [INFO] [stdout] 284 | let first_op = entries.next().await; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 285 | assert_eq!(first_op.unwrap().unwrap().operation, Operation::Delete); [INFO] [stdout] | -------- type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `first_op` an explicit type [INFO] [stdout] | [INFO] [stdout] 284 | let first_op: /* Type */ = entries.next().await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:290:22 [INFO] [stdout] | [INFO] [stdout] 290 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:291:22 [INFO] [stdout] | [INFO] [stdout] 291 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 292 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 293 | | .connect(server.client_url()) [INFO] [stdout] 294 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:299:18 [INFO] [stdout] | [INFO] [stdout] 299 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 300 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 301 | | bucket: "delete".into(), [INFO] [stdout] 302 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 307 | | }) [INFO] [stdout] 308 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:311:24 [INFO] [stdout] | [INFO] [stdout] 311 | let revision = kv.put("key", payload.clone()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:312:21 [INFO] [stdout] | [INFO] [stdout] 312 | let value = kv.get("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:316:22 [INFO] [stdout] | [INFO] [stdout] 316 | let failed = kv [INFO] [stdout] | ______________________^ [INFO] [stdout] 317 | | .delete_expect_revision("key", Some(wrong_revision)) [INFO] [stdout] 318 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:322:9 [INFO] [stdout] | [INFO] [stdout] 322 | / kv.delete_expect_revision("key", Some(revision)) [INFO] [stdout] 323 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:325:18 [INFO] [stdout] | [INFO] [stdout] 325 | let ss = kv.get("kv").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:328:27 [INFO] [stdout] | [INFO] [stdout] 328 | let mut entries = kv.history("key").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:330:13 [INFO] [stdout] | [INFO] [stdout] 330 | let first_op = entries.next().await; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 331 | assert_eq!(first_op.unwrap().unwrap().operation, Operation::Put); [INFO] [stdout] | -------- type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `first_op` an explicit type [INFO] [stdout] | [INFO] [stdout] 330 | let first_op: /* Type */ = entries.next().await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:333:13 [INFO] [stdout] | [INFO] [stdout] 333 | let first_op = entries.next().await; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 334 | assert_eq!(first_op.unwrap().unwrap().operation, Operation::Delete); [INFO] [stdout] | -------- type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `first_op` an explicit type [INFO] [stdout] | [INFO] [stdout] 333 | let first_op: /* Type */ = entries.next().await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:339:22 [INFO] [stdout] | [INFO] [stdout] 339 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:340:22 [INFO] [stdout] | [INFO] [stdout] 340 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 341 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 342 | | .connect(server.client_url()) [INFO] [stdout] 343 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:348:18 [INFO] [stdout] | [INFO] [stdout] 348 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 349 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 350 | | bucket: "purge".into(), [INFO] [stdout] 351 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 356 | | }) [INFO] [stdout] 357 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:359:9 [INFO] [stdout] | [INFO] [stdout] 359 | kv.put("dz", "0".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:360:9 [INFO] [stdout] | [INFO] [stdout] 360 | kv.put("dz", "1".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:361:9 [INFO] [stdout] | [INFO] [stdout] 361 | kv.put("dz", "2".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:362:9 [INFO] [stdout] | [INFO] [stdout] 362 | kv.put("dz", "3".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:363:9 [INFO] [stdout] | [INFO] [stdout] 363 | kv.put("dz", "4".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:364:9 [INFO] [stdout] | [INFO] [stdout] 364 | kv.put("dz", "5".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:366:9 [INFO] [stdout] | [INFO] [stdout] 366 | kv.put("baz", "0".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:367:9 [INFO] [stdout] | [INFO] [stdout] 367 | kv.put("baz", "1".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:368:9 [INFO] [stdout] | [INFO] [stdout] 368 | kv.put("baz", "2".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:370:23 [INFO] [stdout] | [INFO] [stdout] 370 | let history = kv.history("dz").await.unwrap().count().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:372:9 [INFO] [stdout] | [INFO] [stdout] 372 | kv.purge("dz").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:373:23 [INFO] [stdout] | [INFO] [stdout] 373 | let history = kv.history("dz").await.unwrap().count().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:379:22 [INFO] [stdout] | [INFO] [stdout] 379 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:380:22 [INFO] [stdout] | [INFO] [stdout] 380 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 381 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 382 | | .connect(server.client_url()) [INFO] [stdout] 383 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:388:18 [INFO] [stdout] | [INFO] [stdout] 388 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 389 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 390 | | bucket: "purge".into(), [INFO] [stdout] 391 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 396 | | }) [INFO] [stdout] 397 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:399:9 [INFO] [stdout] | [INFO] [stdout] 399 | kv.put("dz", "0".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:400:9 [INFO] [stdout] | [INFO] [stdout] 400 | kv.put("dz", "1".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:401:9 [INFO] [stdout] | [INFO] [stdout] 401 | kv.put("dz", "2".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:402:9 [INFO] [stdout] | [INFO] [stdout] 402 | kv.put("dz", "3".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:403:9 [INFO] [stdout] | [INFO] [stdout] 403 | kv.put("dz", "4".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:404:24 [INFO] [stdout] | [INFO] [stdout] 404 | let revision = kv.put("dz", "5".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:406:9 [INFO] [stdout] | [INFO] [stdout] 406 | kv.put("baz", "0".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:407:9 [INFO] [stdout] | [INFO] [stdout] 407 | kv.put("baz", "1".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:408:9 [INFO] [stdout] | [INFO] [stdout] 408 | kv.put("baz", "2".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:410:23 [INFO] [stdout] | [INFO] [stdout] 410 | let history = kv.history("dz").await.unwrap().count().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:414:22 [INFO] [stdout] | [INFO] [stdout] 414 | let failed = kv [INFO] [stdout] | ______________________^ [INFO] [stdout] 415 | | .purge_expect_revision("dz", Some(wrong_revision)) [INFO] [stdout] 416 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:420:9 [INFO] [stdout] | [INFO] [stdout] 420 | / kv.purge_expect_revision("dz", Some(revision)) [INFO] [stdout] 421 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:423:23 [INFO] [stdout] | [INFO] [stdout] 423 | let history = kv.history("dz").await.unwrap().count().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:429:22 [INFO] [stdout] | [INFO] [stdout] 429 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:430:22 [INFO] [stdout] | [INFO] [stdout] 430 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 431 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 432 | | .connect(server.client_url()) [INFO] [stdout] 433 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:438:18 [INFO] [stdout] | [INFO] [stdout] 438 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 439 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 440 | | bucket: "history".into(), [INFO] [stdout] 441 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 446 | | }) [INFO] [stdout] 447 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:450:13 [INFO] [stdout] | [INFO] [stdout] 450 | kv.put("key", format!("{i}").into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:453:27 [INFO] [stdout] | [INFO] [stdout] 453 | let mut history = kv.history("key").await.unwrap().enumerate(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:456:25 [INFO] [stdout] | [INFO] [stdout] 456 | let entry = entry.unwrap(); [INFO] [stdout] | ^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:467:22 [INFO] [stdout] | [INFO] [stdout] 467 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:468:22 [INFO] [stdout] | [INFO] [stdout] 468 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 469 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 470 | | .connect(server.client_url()) [INFO] [stdout] 471 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:476:18 [INFO] [stdout] | [INFO] [stdout] 476 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 477 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 478 | | bucket: "history".to_string(), [INFO] [stdout] 479 | | description: "test_description".to_string(), [INFO] [stdout] ... | [INFO] [stdout] 484 | | }) [INFO] [stdout] 485 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:489:9 [INFO] [stdout] | [INFO] [stdout] 489 | kv.put("foo", 22.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:490:25 [INFO] [stdout] | [INFO] [stdout] 490 | let mut watch = kv.watch("foo").await.unwrap().enumerate(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:491:9 [INFO] [stdout] | [INFO] [stdout] 491 | client.flush().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:498:21 [INFO] [stdout] | [INFO] [stdout] 498 | kv.put("foo", i.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:508:21 [INFO] [stdout] | [INFO] [stdout] 508 | kv.put("var", i.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:513:25 [INFO] [stdout] | [INFO] [stdout] 513 | let entry = entry.unwrap(); [INFO] [stdout] | ^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:527:22 [INFO] [stdout] | [INFO] [stdout] 527 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:528:22 [INFO] [stdout] | [INFO] [stdout] 528 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 529 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 530 | | .connect(server.client_url()) [INFO] [stdout] 531 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:536:18 [INFO] [stdout] | [INFO] [stdout] 536 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 537 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 538 | | bucket: "history".into(), [INFO] [stdout] 539 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 544 | | }) [INFO] [stdout] 545 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:549:9 [INFO] [stdout] | [INFO] [stdout] 549 | kv.put("foo", 22.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:550:25 [INFO] [stdout] | [INFO] [stdout] 550 | let mut watch = kv.watch("foo").await.unwrap().enumerate(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:557:21 [INFO] [stdout] | [INFO] [stdout] 557 | kv.put("foo", i.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:567:21 [INFO] [stdout] | [INFO] [stdout] 567 | kv.put("var", i.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:572:25 [INFO] [stdout] | [INFO] [stdout] 572 | let entry = entry.unwrap(); [INFO] [stdout] | ^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:586:22 [INFO] [stdout] | [INFO] [stdout] 586 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:587:22 [INFO] [stdout] | [INFO] [stdout] 587 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 588 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 589 | | .connect(server.client_url()) [INFO] [stdout] 590 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:595:18 [INFO] [stdout] | [INFO] [stdout] 595 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 596 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 597 | | bucket: "history".into(), [INFO] [stdout] 598 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 603 | | }) [INFO] [stdout] 604 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:608:9 [INFO] [stdout] | [INFO] [stdout] 608 | kv.put("foo.bar", 42.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:609:25 [INFO] [stdout] | [INFO] [stdout] 609 | let mut watch = kv.watch_with_history("foo.>").await.unwrap().enumerate(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:616:21 [INFO] [stdout] | [INFO] [stdout] 616 | / kv.put(format!("foo.{i}"), i.to_string().into()) [INFO] [stdout] 617 | | .await [INFO] [stdout] | |______________________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:628:21 [INFO] [stdout] | [INFO] [stdout] 628 | kv.put("var", i.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:635:26 [INFO] [stdout] | [INFO] [stdout] 635 | let (_, entry) = watch.next().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:636:21 [INFO] [stdout] | [INFO] [stdout] 636 | let entry = entry.unwrap(); [INFO] [stdout] | ^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:645:25 [INFO] [stdout] | [INFO] [stdout] 645 | let entry = entry.unwrap(); [INFO] [stdout] | ^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:661:22 [INFO] [stdout] | [INFO] [stdout] 661 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:662:22 [INFO] [stdout] | [INFO] [stdout] 662 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 663 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 664 | | .connect(server.client_url()) [INFO] [stdout] 665 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:670:18 [INFO] [stdout] | [INFO] [stdout] 670 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 671 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 672 | | bucket: "history".into(), [INFO] [stdout] 673 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 678 | | }) [INFO] [stdout] 679 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:682:25 [INFO] [stdout] | [INFO] [stdout] 682 | let mut watch = kv.watch_all().await.unwrap().enumerate(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:690:21 [INFO] [stdout] | [INFO] [stdout] 690 | kv.put("bar", i.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:699:21 [INFO] [stdout] | [INFO] [stdout] 699 | kv.put("foo", i.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:705:25 [INFO] [stdout] | [INFO] [stdout] 705 | let entry = entry.unwrap(); [INFO] [stdout] | ^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:715:22 [INFO] [stdout] | [INFO] [stdout] 715 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:716:22 [INFO] [stdout] | [INFO] [stdout] 716 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 717 | | .connect(server.client_url()) [INFO] [stdout] 718 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:723:18 [INFO] [stdout] | [INFO] [stdout] 723 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 724 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 725 | | bucket: "bucket".into(), [INFO] [stdout] 726 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 729 | | }) [INFO] [stdout] 730 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:733:9 [INFO] [stdout] | [INFO] [stdout] 733 | kv.put("foo", "bar".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:734:9 [INFO] [stdout] | [INFO] [stdout] 734 | kv.put("foo", "baz".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:735:9 [INFO] [stdout] | [INFO] [stdout] 735 | kv.put("bar", "foo".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:736:9 [INFO] [stdout] | [INFO] [stdout] 736 | kv.put("bar", "bar".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:737:9 [INFO] [stdout] | [INFO] [stdout] 737 | kv.put("baz", "foo".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:739:25 [INFO] [stdout] | [INFO] [stdout] 739 | let mut watch = kv.watch_from_revision("foo", 2).await.unwrap().take(1); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:740:19 [INFO] [stdout] | [INFO] [stdout] 740 | let key = watch.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:745:25 [INFO] [stdout] | [INFO] [stdout] 745 | let mut watch = kv.watch_all_from_revision(3).await.unwrap().take(3); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:746:19 [INFO] [stdout] | [INFO] [stdout] 746 | let key = watch.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:750:19 [INFO] [stdout] | [INFO] [stdout] 750 | let key = watch.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:753:19 [INFO] [stdout] | [INFO] [stdout] 753 | let key = watch.next().await.unwrap().unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:760:22 [INFO] [stdout] | [INFO] [stdout] 760 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:761:22 [INFO] [stdout] | [INFO] [stdout] 761 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 762 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 763 | | .connect(server.client_url()) [INFO] [stdout] 764 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:769:18 [INFO] [stdout] | [INFO] [stdout] 769 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 770 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 771 | | bucket: "history".into(), [INFO] [stdout] 772 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 777 | | }) [INFO] [stdout] 778 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:782:13 [INFO] [stdout] | [INFO] [stdout] 782 | kv.put("bar", i.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:785:13 [INFO] [stdout] | [INFO] [stdout] 785 | kv.put("foo", i.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:788:24 [INFO] [stdout] | [INFO] [stdout] 788 | let mut keys = kv [INFO] [stdout] | ________________________^ [INFO] [stdout] 789 | | .keys() [INFO] [stdout] 790 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:788:24 [INFO] [stdout] | [INFO] [stdout] 788 | let mut keys = kv [INFO] [stdout] | ________________________^ [INFO] [stdout] 789 | | .keys() [INFO] [stdout] 790 | | .await [INFO] [stdout] 791 | | .unwrap() [INFO] [stdout] 792 | | .try_collect::>() [INFO] [stdout] 793 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:799:9 [INFO] [stdout] | [INFO] [stdout] 799 | kv.delete("bar").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:800:20 [INFO] [stdout] | [INFO] [stdout] 800 | let keys = kv [INFO] [stdout] | ____________________^ [INFO] [stdout] 801 | | .keys() [INFO] [stdout] 802 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:800:20 [INFO] [stdout] | [INFO] [stdout] 800 | let keys = kv [INFO] [stdout] | ____________________^ [INFO] [stdout] 801 | | .keys() [INFO] [stdout] 802 | | .await [INFO] [stdout] 803 | | .unwrap() [INFO] [stdout] 804 | | .try_collect::>() [INFO] [stdout] 805 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:811:13 [INFO] [stdout] | [INFO] [stdout] 811 | kv.put("bar", i.to_string().into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:813:9 [INFO] [stdout] | [INFO] [stdout] 813 | kv.purge("foo").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:814:20 [INFO] [stdout] | [INFO] [stdout] 814 | let keys = kv [INFO] [stdout] | ____________________^ [INFO] [stdout] 815 | | .keys() [INFO] [stdout] 816 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:814:20 [INFO] [stdout] | [INFO] [stdout] 814 | let keys = kv [INFO] [stdout] | ____________________^ [INFO] [stdout] 815 | | .keys() [INFO] [stdout] 816 | | .await [INFO] [stdout] 817 | | .unwrap() [INFO] [stdout] 818 | | .try_collect::>() [INFO] [stdout] 819 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:823:18 [INFO] [stdout] | [INFO] [stdout] 823 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 824 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 825 | | bucket: "history2".into(), [INFO] [stdout] 826 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 832 | | }) [INFO] [stdout] 833 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:836:9 [INFO] [stdout] | [INFO] [stdout] 836 | kv.put("baz", "value".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:840:32 [INFO] [stdout] | [INFO] [stdout] 840 | let keys = keys.try_collect::>().await.unwrap(); [INFO] [stdout] | ^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:840:32 [INFO] [stdout] | [INFO] [stdout] 840 | let keys = keys.try_collect::>().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:846:31 [INFO] [stdout] | [INFO] [stdout] 846 | Err(e) => Err(e.into()), [INFO] [stdout] | ^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:857:22 [INFO] [stdout] | [INFO] [stdout] 857 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:858:22 [INFO] [stdout] | [INFO] [stdout] 858 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 859 | | .event_callback(|event| async move { println!("event: {event:?}") }) [INFO] [stdout] 860 | | .connect(server.client_url()) [INFO] [stdout] 861 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:866:18 [INFO] [stdout] | [INFO] [stdout] 866 | let kv = context [INFO] [stdout] | __________________^ [INFO] [stdout] 867 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 868 | | bucket: "test".into(), [INFO] [stdout] 869 | | description: "test_description".into(), [INFO] [stdout] ... | [INFO] [stdout] 879 | | }) [INFO] [stdout] 880 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:883:29 [INFO] [stdout] | [INFO] [stdout] 883 | let mut subscribe = client.subscribe("bar.>").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:885:9 [INFO] [stdout] | [INFO] [stdout] 885 | kv.put("key", "data".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:887:23 [INFO] [stdout] | [INFO] [stdout] 887 | let message = subscribe.next().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:893:26 [INFO] [stdout] | [INFO] [stdout] 893 | let hub_server = nats_server::run_server("tests/configs/jetstream_hub.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:894:27 [INFO] [stdout] | [INFO] [stdout] 894 | let leaf_server = nats_server::run_server("tests/configs/jetstream_leaf.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:896:19 [INFO] [stdout] | [INFO] [stdout] 896 | let hub = async_nats::connect(hub_server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:896:19 [INFO] [stdout] | [INFO] [stdout] 896 | let hub = async_nats::connect(hub_server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:897:20 [INFO] [stdout] | [INFO] [stdout] 897 | let leaf = async_nats::connect(leaf_server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:897:20 [INFO] [stdout] | [INFO] [stdout] 897 | let leaf = async_nats::connect(leaf_server.client_url()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:901:22 [INFO] [stdout] | [INFO] [stdout] 901 | let hub_kv = hub_js [INFO] [stdout] | ______________________^ [INFO] [stdout] 902 | | .create_key_value(async_nats::jetstream::kv::Config { [INFO] [stdout] 903 | | bucket: "TEST".into(), [INFO] [stdout] 904 | | ..Default::default() [INFO] [stdout] 905 | | }) [INFO] [stdout] 906 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:908:9 [INFO] [stdout] | [INFO] [stdout] 908 | hub_kv.put("name", "derek".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:909:9 [INFO] [stdout] | [INFO] [stdout] 909 | hub_kv.put("age", "22".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:921:9 [INFO] [stdout] | [INFO] [stdout] 921 | leaf_js.create_key_value(mirror_bucket).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:923:22 [INFO] [stdout] | [INFO] [stdout] 923 | let mirror = leaf_js.get_stream("KV_MIRROR").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:932:24 [INFO] [stdout] | [INFO] [stdout] 932 | let local_kv = leaf_js.get_key_value("MIRROR").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:934:9 [INFO] [stdout] | [INFO] [stdout] 934 | local_kv.put("name", "rip".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the size for values of type `[u8]` cannot be known at compilation time [INFO] [stdout] --> tests/kv_tests.rs:937:25 [INFO] [stdout] | [INFO] [stdout] 937 | Ok(Some(name)) => { [INFO] [stdout] | ^^^^ doesn't have a size known at compile-time [INFO] [stdout] | [INFO] [stdout] = help: the trait `Sized` is not implemented for `[u8]` [INFO] [stdout] = note: all local variables must have a statically known size [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the size for values of type `[u8]` cannot be known at compilation time [INFO] [stdout] --> tests/kv_tests.rs:937:20 [INFO] [stdout] | [INFO] [stdout] 937 | Ok(Some(name)) => { [INFO] [stdout] | ^^^^^^^^^^ doesn't have a size known at compile-time [INFO] [stdout] | [INFO] [stdout] = help: the trait `Sized` is not implemented for `[u8]` [INFO] [stdout] note: required by a bound in `Some` [INFO] [stdout] --> /rustc/c2e32f1c9652b13ed99608599c1e855462f421f3/library/core/src/option.rs:607:4 [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the size for values of type `[u8]` cannot be known at compilation time [INFO] [stdout] --> tests/kv_tests.rs:936:40 [INFO] [stdout] | [INFO] [stdout] 936 | match local_kv.get("name").await { [INFO] [stdout] | ^^^^^ doesn't have a size known at compile-time [INFO] [stdout] | [INFO] [stdout] = help: the trait `Sized` is not implemented for `[u8]` [INFO] [stdout] note: required by an implicit `Sized` bound in `Option` [INFO] [stdout] --> /rustc/c2e32f1c9652b13ed99608599c1e855462f421f3/library/core/src/option.rs:599:0 [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:935:9 [INFO] [stdout] | [INFO] [stdout] 935 | / tryhard::retry_fn(|| async { [INFO] [stdout] 936 | | match local_kv.get("name").await { [INFO] [stdout] 937 | | Ok(Some(name)) => { [INFO] [stdout] 938 | | assert_eq!(from_utf8(&name).unwrap(), "rip"); [INFO] [stdout] ... | [INFO] [stdout] 945 | | .exponential_backoff(Duration::from_millis(500)) [INFO] [stdout] 946 | | .await [INFO] [stdout] | |______________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:952:20 [INFO] [stdout] | [INFO] [stdout] 952 | let test = leaf_hub_js.get_key_value("TEST").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:954:9 [INFO] [stdout] | [INFO] [stdout] 954 | test.put("name", "ivan".into()).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:955:20 [INFO] [stdout] | [INFO] [stdout] 955 | let name = test.get("name").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:958:9 [INFO] [stdout] | [INFO] [stdout] 958 | test.purge("name").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:959:20 [INFO] [stdout] | [INFO] [stdout] 959 | let name = test.get("name").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:965:9 [INFO] [stdout] | [INFO] [stdout] 965 | local_kv.get("name").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] --> tests/kv_tests.rs:970:22 [INFO] [stdout] | [INFO] [stdout] 970 | let server = nats_server::run_server("tests/configs/jetstream.conf"); [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `nats_server` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `nats_server`, use `cargo add nats_server` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:972:22 [INFO] [stdout] | [INFO] [stdout] 972 | let client = ConnectOptions::new() [INFO] [stdout] | ______________________^ [INFO] [stdout] 973 | | .connect(server.client_url()) [INFO] [stdout] 974 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:979:9 [INFO] [stdout] | [INFO] [stdout] 979 | / context [INFO] [stdout] 980 | | .create_stream(async_nats::jetstream::stream::Config { [INFO] [stdout] 981 | | subjects: vec!["A.>".into(), "B.>".into()], [INFO] [stdout] 982 | | name: "source".into(), [INFO] [stdout] ... | [INFO] [stdout] 990 | | }) [INFO] [stdout] 991 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:994:25 [INFO] [stdout] | [INFO] [stdout] 994 | let kv_stream = context [INFO] [stdout] | _________________________^ [INFO] [stdout] 995 | | .create_stream(stream::Config { [INFO] [stdout] 996 | | subjects: vec!["$KV.test.>".into()], [INFO] [stdout] 997 | | name: "KV_test".into(), [INFO] [stdout] ... | [INFO] [stdout] 1000 | | }) [INFO] [stdout] 1001 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1004:18 [INFO] [stdout] | [INFO] [stdout] 1004 | let kv = context.get_key_value("test").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1007:9 [INFO] [stdout] | [INFO] [stdout] 1007 | / context [INFO] [stdout] 1008 | | .publish("B.foo", "data".into()) [INFO] [stdout] 1009 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1007:9 [INFO] [stdout] | [INFO] [stdout] 1007 | / context [INFO] [stdout] 1008 | | .publish("B.foo", "data".into()) [INFO] [stdout] 1009 | | .await [INFO] [stdout] 1010 | | .unwrap() [INFO] [stdout] 1011 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1013:9 [INFO] [stdout] | [INFO] [stdout] 1013 | / context [INFO] [stdout] 1014 | | .publish("B.bar", "data".into()) [INFO] [stdout] 1015 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1013:9 [INFO] [stdout] | [INFO] [stdout] 1013 | / context [INFO] [stdout] 1014 | | .publish("B.bar", "data".into()) [INFO] [stdout] 1015 | | .await [INFO] [stdout] 1016 | | .unwrap() [INFO] [stdout] 1017 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1021:9 [INFO] [stdout] | [INFO] [stdout] 1021 | / context [INFO] [stdout] 1022 | | .publish("A.orange", "key".into()) [INFO] [stdout] 1023 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1021:9 [INFO] [stdout] | [INFO] [stdout] 1021 | / context [INFO] [stdout] 1022 | | .publish("A.orange", "key".into()) [INFO] [stdout] 1023 | | .await [INFO] [stdout] 1024 | | .unwrap() [INFO] [stdout] 1025 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1027:9 [INFO] [stdout] | [INFO] [stdout] 1027 | / context [INFO] [stdout] 1028 | | .publish("A.tomato", "hello".into()) [INFO] [stdout] 1029 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1027:9 [INFO] [stdout] | [INFO] [stdout] 1027 | / context [INFO] [stdout] 1028 | | .publish("A.tomato", "hello".into()) [INFO] [stdout] 1029 | | .await [INFO] [stdout] 1030 | | .unwrap() [INFO] [stdout] 1031 | | .await [INFO] [stdout] | |__________________^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1034:23 [INFO] [stdout] | [INFO] [stdout] 1034 | assert_eq!(1, kv.entry("orange").await.unwrap().unwrap().revision); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1035:23 [INFO] [stdout] | [INFO] [stdout] 1035 | assert_eq!(2, kv.entry("tomato").await.unwrap().unwrap().revision); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1041:9 [INFO] [stdout] | [INFO] [stdout] 1041 | context.update_stream(config).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1043:18 [INFO] [stdout] | [INFO] [stdout] 1043 | let kv = context.get_key_value("test").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1045:23 [INFO] [stdout] | [INFO] [stdout] 1045 | assert_eq!(1, kv.entry("orange").await.unwrap().unwrap().revision); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/kv_tests.rs:1046:23 [INFO] [stdout] | [INFO] [stdout] 1046 | assert_eq!(2, kv.entry("tomato").await.unwrap().unwrap().revision); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:844:30 [INFO] [stdout] | [INFO] [stdout] 844 | Ok::<(), async_nats::Error>(()) [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] --> tests/kv_tests.rs:939:30 [INFO] [stdout] | [INFO] [stdout] 939 | Ok::<(), async_nats::Error>(()) [INFO] [stdout] | ^^^^^^^^^^ use of unresolved module or unlinked crate `async_nats` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `async_nats`, use `cargo add async_nats` to add it to your `Cargo.toml` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0277, E0282, E0432, E0433. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0277`. [INFO] [stdout] [INFO] [stderr] error: could not compile `async-nats-wrpc` (test "kv_tests") due to 270 previous errors [INFO] running `Command { std: "docker" "inspect" "3c32c2edaa930cd0b97080d1ba62a01d6a9e387d07409423e0cc2d3c8fa4869f", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "3c32c2edaa930cd0b97080d1ba62a01d6a9e387d07409423e0cc2d3c8fa4869f", kill_on_drop: false }` [INFO] [stdout] 3c32c2edaa930cd0b97080d1ba62a01d6a9e387d07409423e0cc2d3c8fa4869f