ruststream 0.4.0

Async messaging framework for Rust: broker-agnostic traits, router, codecs, and a conformance harness for broker authors.
Documentation

Build #3579649 2026-06-14 18:01:21

# rustc version rustc 1.98.0-nightly (1f087276b 2026-06-13)

# docs.rs version docsrs 0.0.0 (886bc7a22b1adc4b387ce1343447fe3af98d9ce5 2026-06-14 )

# build log [INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "DOCS_RS=1" "-w" "/opt/rustwide/workdir" "--user" "1001:1001" "5f4eb37fcdebff742bc84f7c319bd3514a8fa820b7ed109b9fb4a4bc04de6755" "/opt/rustwide/cargo-home/bin/cargo" "+nightly" "rustdoc" "--lib" "-Zrustdoc-map" "--config" "build.rustdocflags=[\"--cfg\", \"docsrs\", \"-Z\", \"unstable-options\", \"--emit=invocation-specific\", \"--resource-suffix\", \"-20260613-1.98.0-nightly-1f087276b\", \"--static-root-path\", \"/-/rustdoc.static/\", \"--cap-lints\", \"warn\", \"--extern-html-root-takes-precedence\"]" "--offline" "-Zunstable-options" "--config=doc.extern-map.registries.crates-io=\"https://docs.rs/{pkg_name}/{version}/x86_64-unknown-linux-gnu\"" "-Zrustdoc-scrape-examples" "-j6" "--target" "x86_64-unknown-linux-gnu", kill_on_drop: false }` [INFO] [stderr] warning: Rustdoc did not scrape the following examples because they require dev-dependencies: asyncapi_http, codecs, context, failure_policy, lifespan, logging, logging_middleware, macro_app, metrics_http, middleware, middleware_app_scope, middleware_router_scope, post_settle, publishing, quickstart, retry, routed_service, routing, subscribers, tutorial [INFO] [stderr] If you want Rustdoc to scrape these examples, then add `doc-scrape-examples = true` [INFO] [stderr] to the [[example]] target configuration of at least one example. [INFO] [stderr] warning: target filter specified, but no targets matched; this is a no-op [INFO] [stderr] Documenting ruststream v0.4.0 (/opt/rustwide/workdir) [INFO] [stderr] warning: unresolved link to `codec::MsgpackCodec` [INFO] [stderr] --> src/lib.rs:12:20 [INFO] [stderr] | [INFO] [stderr] 12 | //! * `msgpack`: [`codec::MsgpackCodec`]. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^ no item named `MsgpackCodec` in module `codec` [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(rustdoc::broken_intra_doc_links)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `codec::CborCodec` [INFO] [stderr] --> src/lib.rs:13:17 [INFO] [stderr] | [INFO] [stderr] 13 | //! * `cbor`: [`codec::CborCodec`]. [INFO] [stderr] | ^^^^^^^^^^^^^^^^ no item named `CborCodec` in module `codec` [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `memory::MemoryBroker` [INFO] [stderr] --> src/lib.rs:14:19 [INFO] [stderr] | [INFO] [stderr] 14 | //! * `memory`: [`memory::MemoryBroker`], an in-process broker usable in applications, prototypes [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ no item named `memory` in scope [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `app` [INFO] [stderr] --> src/lib.rs:16:61 [INFO] [stderr] | [INFO] [stderr] 16 | //! * `macros`: the `#[subscriber]`, [`#[ruststream::app]`](macro@app), and [INFO] [stderr] | ^^^^^^^^^ no item named `app` in scope [INFO] [stderr] | [INFO] [stderr] = help: to escape `[` and `]` characters, add '\' before them like `\[` or `\]` [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `Message` [INFO] [stderr] --> src/lib.rs:17:30 [INFO] [stderr] | [INFO] [stderr] 17 | //! [`#[derive(Message)]`](macro@Message) macros. [INFO] [stderr] | ^^^^^^^^^^^^^ this link resolves to the trait `Message`, which is not in the macro namespace [INFO] [stderr] | [INFO] [stderr] help: to link to the trait, prefix with `trait@` [INFO] [stderr] | [INFO] [stderr] 17 - //! [`#[derive(Message)]`](macro@Message) macros. [INFO] [stderr] 17 + //! [`#[derive(Message)]`](trait@Message) macros. [INFO] [stderr] | [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `logging::init` [INFO] [stderr] --> src/lib.rs:21:10 [INFO] [stderr] | [INFO] [stderr] 21 | //! ([`logging::init`]). The generated `cli` `run` command installs it automatically. [INFO] [stderr] | ^^^^^^^^^^^^^ no item named `logging` in scope [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `conformance::harness` [INFO] [stderr] --> src/lib.rs:22:28 [INFO] [stderr] | [INFO] [stderr] 22 | //! * `conformance`: the [`conformance::harness`] contract suite, per-capability suites in [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ no item named `conformance` in scope [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `conformance::capabilities` [INFO] [stderr] --> src/lib.rs:23:9 [INFO] [stderr] | [INFO] [stderr] 23 | //! [`conformance::capabilities`], and broker-agnostic [`conformance::helpers`] for application [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^ no item named `conformance` in scope [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `conformance::helpers` [INFO] [stderr] --> src/lib.rs:23:60 [INFO] [stderr] | [INFO] [stderr] 23 | //! [`conformance::capabilities`], and broker-agnostic [`conformance::helpers`] for application [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ no item named `conformance` in scope [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `memory::MemoryBroker` [INFO] [stderr] --> src/lib.rs:25:40 [INFO] [stderr] | [INFO] [stderr] 25 | //! `memory` too to run it against [`memory::MemoryBroker`]). [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ no item named `memory` in scope [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `crate::conformance::harness::lifecycle` [INFO] [stderr] --> src/broker.rs:26:41 [INFO] [stderr] | [INFO] [stderr] 26 | /// [`conformance::harness::lifecycle`](crate::conformance::harness::lifecycle) checks the whole [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no item named `conformance` in module `ruststream` [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `crate::conformance::harness` [INFO] [stderr] --> src/testing.rs:13:11 [INFO] [stderr] | [INFO] [stderr] 13 | //! The [`crate::conformance::harness`] suite verifies exactly this Core-routing surface. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ no item named `conformance` in module `ruststream` [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `MsgpackCodec` [INFO] [stderr] --> src/codec/mod.rs:13:20 [INFO] [stderr] | [INFO] [stderr] 13 | //! * `msgpack`: [`MsgpackCodec`] via `rmp-serde`. [INFO] [stderr] | ^^^^^^^^^^^^ no item named `MsgpackCodec` in scope [INFO] [stderr] | [INFO] [stderr] = help: to escape `[` and `]` characters, add '\' before them like `\[` or `\]` [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `CborCodec` [INFO] [stderr] --> src/codec/mod.rs:14:17 [INFO] [stderr] | [INFO] [stderr] 14 | //! * `cbor`: [`CborCodec`] via `ciborium`. [INFO] [stderr] | ^^^^^^^^^ no item named `CborCodec` in scope [INFO] [stderr] | [INFO] [stderr] = help: to escape `[` and `]` characters, add '\' before them like `\[` or `\]` [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `schemars::JsonSchema` [INFO] [stderr] --> src/runtime/batch.rs:203:73 [INFO] [stderr] | [INFO] [stderr] 203 | /// The element type's serialized JSON Schema, when it implements [`schemars::JsonSchema`] and [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ no item named `schemars` in scope [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `schemars::JsonSchema` [INFO] [stderr] --> src/runtime/batch_publishing.rs:69:73 [INFO] [stderr] | [INFO] [stderr] 69 | /// The element type's serialized JSON Schema, when it implements [`schemars::JsonSchema`] [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ no item named `schemars` in scope [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `crate::app` [INFO] [stderr] --> src/runtime/cli.rs:1:65 [INFO] [stderr] | [INFO] [stderr] 1 | //! The process entry point generated by [`#[ruststream::app]`](macro@crate::app). [INFO] [stderr] | ^^^^^^^^^^^^^^^^ no item named `app` in module `ruststream` [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `crate::logging` [INFO] [stderr] --> src/runtime/cli.rs:9:37 [INFO] [stderr] | [INFO] [stderr] 9 | //! the colored console logger ([`crate::logging`]), so a scaffolded service prints logs without [INFO] [stderr] | ^^^^^^^^^^^^^^ no item named `logging` in module `ruststream` [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `crate::asyncapi` [INFO] [stderr] --> src/runtime/cli.rs:11:67 [INFO] [stderr] | [INFO] [stderr] 11 | //! - `asyncapi gen [-o <file>] [--yaml]` builds the [`AsyncAPI`](crate::asyncapi) document for the [INFO] [stderr] | ^^^^^^^^^^^^^^^ no item named `asyncapi` in module `ruststream` [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `crate::app` [INFO] [stderr] --> src/runtime/cli.rs:79:42 [INFO] [stderr] | [INFO] [stderr] 79 | /// Called by the [`#[ruststream::app]`](macro@crate::app) expansion; you rarely call it directly. [INFO] [stderr] | ^^^^^^^^^^^^^^^^ no item named `app` in module `ruststream` [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `schemars::JsonSchema` [INFO] [stderr] --> src/runtime/metadata.rs:23:11 [INFO] [stderr] | [INFO] [stderr] 23 | /// [`schemars::JsonSchema`] (captured under the `asyncapi` feature). Feeds the `AsyncAPI` [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ no item named `schemars` in scope [INFO] [stderr] [INFO] [stderr] warning: public documentation for `TypedPublisher` links to private item `crate::subscriber` [INFO] [stderr] --> src/runtime/publish.rs:273:14 [INFO] [stderr] | [INFO] [stderr] 273 | /// [macro]: crate::subscriber [INFO] [stderr] | ^^^^^^^^^^^^^^^^^ this item is private [INFO] [stderr] | [INFO] [stderr] = note: this link will resolve properly if you pass `--document-private-items` [INFO] [stderr] = note: `#[warn(rustdoc::private_intra_doc_links)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `schemars::JsonSchema` [INFO] [stderr] --> src/runtime/publishing.rs:63:71 [INFO] [stderr] | [INFO] [stderr] 63 | /// The input type's serialized JSON Schema, when it implements [`schemars::JsonSchema`] and the [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ no item named `schemars` in scope [INFO] [stderr] [INFO] [stderr] warning: unresolved link to `schemars::JsonSchema` [INFO] [stderr] --> src/runtime/subscriber_def.rs:36:71 [INFO] [stderr] | [INFO] [stderr] 36 | /// The input type's serialized JSON Schema, when it implements [`schemars::JsonSchema`] and the [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ no item named `schemars` in scope [INFO] [stderr] [INFO] [stderr] warning: `ruststream` (lib doc) generated 24 warnings [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 1.32s [INFO] [stderr] Generated /opt/rustwide/target/x86_64-unknown-linux-gnu/doc/ruststream/index.html [INFO] running `Command { std: "docker" "inspect" "5f4eb37fcdebff742bc84f7c319bd3514a8fa820b7ed109b9fb4a4bc04de6755", kill_on_drop: false }`