[INFO] fetching crate fluxion-stream 0.8.0...
[INFO] testing fluxion-stream-0.8.0 against beta-2026-03-05 for beta-1.95-1
[INFO] extracting crate fluxion-stream 0.8.0 into /workspace/builds/worker-6-tc2/source
[INFO] started tweaking crates.io crate fluxion-stream 0.8.0
[INFO] removed 0 missing tests
[INFO] finished tweaking crates.io crate fluxion-stream 0.8.0
[INFO] tweaked toml for crates.io crate fluxion-stream 0.8.0 written to /workspace/builds/worker-6-tc2/source/Cargo.toml
[INFO] validating manifest of crates.io crate fluxion-stream 0.8.0 on toolchain beta-2026-03-05
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+beta-2026-03-05" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate crates.io crate fluxion-stream 0.8.0 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" "+beta-2026-03-05" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2026-03-05" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 74480198855bf6618cdad9f43af84e054d4741fdbfd2570bc6d397cf49f6f1ca
[INFO] running `Command { std: "docker" "start" "-a" "74480198855bf6618cdad9f43af84e054d4741fdbfd2570bc6d397cf49f6f1ca", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "74480198855bf6618cdad9f43af84e054d4741fdbfd2570bc6d397cf49f6f1ca", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "74480198855bf6618cdad9f43af84e054d4741fdbfd2570bc6d397cf49f6f1ca", kill_on_drop: false }`
[INFO] [stdout] 74480198855bf6618cdad9f43af84e054d4741fdbfd2570bc6d397cf49f6f1ca
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2026-03-05" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 8fed547dedf9f453c97051c3baac528772c731c2df876591fb6ca4880271eeb8
[INFO] running `Command { std: "docker" "start" "-a" "8fed547dedf9f453c97051c3baac528772c731c2df876591fb6ca4880271eeb8", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.105
[INFO] [stderr]    Compiling unicode-ident v1.0.22
[INFO] [stderr]    Compiling quote v1.0.43
[INFO] [stderr]    Compiling pin-project-lite v0.2.16
[INFO] [stderr]    Compiling portable-atomic v1.13.0
[INFO] [stderr]    Compiling crossbeam-utils v0.8.21
[INFO] [stderr]    Compiling futures-core v0.3.31
[INFO] [stderr]    Compiling futures-sink v0.3.31
[INFO] [stderr]    Compiling portable-atomic-util v0.2.4
[INFO] [stderr]    Compiling memchr v2.7.6
[INFO] [stderr]    Compiling futures-io v0.3.31
[INFO] [stderr]    Compiling slab v0.4.11
[INFO] [stderr]    Compiling pin-utils v0.1.0
[INFO] [stderr]    Compiling libc v0.2.180
[INFO] [stderr]    Compiling futures-task v0.3.31
[INFO] [stderr]    Compiling parking v2.2.1
[INFO] [stderr]    Compiling parking_lot_core v0.9.12
[INFO] [stderr]    Compiling scopeguard v1.2.0
[INFO] [stderr]    Compiling cfg-if v1.0.4
[INFO] [stderr]    Compiling smallvec v1.15.1
[INFO] [stderr]    Compiling spin v0.10.0
[INFO] [stderr]    Compiling lock_api v0.4.14
[INFO] [stderr]    Compiling fastrand v2.3.0
[INFO] [stderr]    Compiling futures-channel v0.3.31
[INFO] [stderr]    Compiling concurrent-queue v2.5.0
[INFO] [stderr]    Compiling event-listener v5.4.1
[INFO] [stderr]    Compiling syn v2.0.114
[INFO] [stderr]    Compiling event-listener-strategy v0.5.4
[INFO] [stderr]    Compiling async-channel v2.5.0
[INFO] [stderr]    Compiling parking_lot v0.12.5
[INFO] [stderr]    Compiling futures-macro v0.3.31
[INFO] [stderr]    Compiling tokio-macros v2.6.0
[INFO] [stderr]    Compiling pin-project-internal v1.1.10
[INFO] [stderr]    Compiling tokio v1.49.0
[INFO] [stderr]    Compiling futures-util v0.3.31
[INFO] [stderr]    Compiling pin-project v1.1.10
[INFO] [stderr]    Compiling futures-executor v0.3.31
[INFO] [stderr]    Compiling futures v0.3.31
[INFO] [stderr]    Compiling fluxion-ordered-merge v0.8.0
[INFO] [stderr]    Compiling fluxion-core v0.8.0
[INFO] [stderr]    Compiling fluxion-stream v0.8.0 (/opt/rustwide/workdir)
[INFO] [stderr]     Finished `dev` profile [unoptimized + debuginfo] target(s) in 12.78s
[INFO] running `Command { std: "docker" "inspect" "8fed547dedf9f453c97051c3baac528772c731c2df876591fb6ca4880271eeb8", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "8fed547dedf9f453c97051c3baac528772c731c2df876591fb6ca4880271eeb8", kill_on_drop: false }`
[INFO] [stdout] 8fed547dedf9f453c97051c3baac528772c731c2df876591fb6ca4880271eeb8
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2026-03-05" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] a3aa8c6be48eccab097e87a1a36700fea3b40459021d01809afcdb8a2e8e8eb2
[INFO] running `Command { std: "docker" "start" "-a" "a3aa8c6be48eccab097e87a1a36700fea3b40459021d01809afcdb8a2e8e8eb2", kill_on_drop: false }`
[INFO] [stderr]    Compiling crossbeam-utils v0.8.21
[INFO] [stderr]    Compiling serde_core v1.0.228
[INFO] [stderr]    Compiling zerocopy v0.8.33
[INFO] [stderr]    Compiling zerocopy-derive v0.8.33
[INFO] [stderr]    Compiling autocfg v1.5.0
[INFO] [stderr]    Compiling serde v1.0.228
[INFO] [stderr]    Compiling zmij v1.0.14
[INFO] [stderr]    Compiling serde_derive v1.0.228
[INFO] [stderr]    Compiling either v1.15.0
[INFO] [stderr]    Compiling rayon-core v1.13.0
[INFO] [stderr]    Compiling serde_json v1.0.149
[INFO] [stderr]    Compiling tokio v1.49.0
[INFO] [stderr]    Compiling itoa v1.0.17
[INFO] [stderr]    Compiling clap_lex v0.7.7
[INFO] [stderr]    Compiling regex-syntax v0.8.8
[INFO] [stderr]    Compiling anstyle v1.0.13
[INFO] [stderr]    Compiling ciborium-io v0.2.2
[INFO] [stderr]    Compiling plotters-backend v0.3.7
[INFO] [stderr]    Compiling clap_builder v4.5.54
[INFO] [stderr]    Compiling same-file v1.0.6
[INFO] [stderr]    Compiling anyhow v1.0.100
[INFO] [stderr]    Compiling cast v0.3.0
[INFO] [stderr]    Compiling itertools v0.13.0
[INFO] [stderr]    Compiling anes v0.1.6
[INFO] [stderr]    Compiling walkdir v2.5.0
[INFO] [stderr]    Compiling oorandom v11.1.5
[INFO] [stderr]    Compiling num-traits v0.2.19
[INFO] [stderr]    Compiling plotters-svg v0.3.7
[INFO] [stderr]    Compiling concurrent-queue v2.5.0
[INFO] [stderr]    Compiling crossbeam-epoch v0.9.18
[INFO] [stderr]    Compiling event-listener v5.4.1
[INFO] [stderr]    Compiling crossbeam-deque v0.8.6
[INFO] [stderr]    Compiling event-listener-strategy v0.5.4
[INFO] [stderr]    Compiling async-channel v2.5.0
[INFO] [stderr]    Compiling regex-automata v0.4.13
[INFO] [stderr]    Compiling criterion-plot v0.6.0
[INFO] [stderr]    Compiling plotters v0.3.7
[INFO] [stderr]    Compiling rayon v1.11.0
[INFO] [stderr]    Compiling clap v4.5.54
[INFO] [stderr]    Compiling regex v1.12.2
[INFO] [stderr]    Compiling fluxion-core v0.8.0
[INFO] [stderr]    Compiling fluxion-test-utils v0.8.0
[INFO] [stderr]    Compiling fluxion-stream v0.8.0 (/opt/rustwide/workdir)
[INFO] [stderr]    Compiling half v2.7.1
[INFO] [stderr]    Compiling ciborium-ll v0.2.2
[INFO] [stderr]    Compiling ciborium v0.2.2
[INFO] [stderr]    Compiling tinytemplate v1.2.1
[INFO] [stderr]    Compiling criterion v0.7.0
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 1m 00s
[INFO] running `Command { std: "docker" "inspect" "a3aa8c6be48eccab097e87a1a36700fea3b40459021d01809afcdb8a2e8e8eb2", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "a3aa8c6be48eccab097e87a1a36700fea3b40459021d01809afcdb8a2e8e8eb2", kill_on_drop: false }`
[INFO] [stdout] a3aa8c6be48eccab097e87a1a36700fea3b40459021d01809afcdb8a2e8e8eb2
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-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=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2026-03-05" "test" "--frozen", kill_on_drop: false }`
[INFO] [stdout] 73ece709c78a41166151c69ae1cf7f35922689bd2f371e6215a40849b55e4a06
[INFO] running `Command { std: "docker" "start" "-a" "73ece709c78a41166151c69ae1cf7f35922689bd2f371e6215a40849b55e4a06", kill_on_drop: false }`
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 0.25s
[INFO] [stdout] 
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/fluxion_stream-cd96627dde5ab05b)
[INFO] [stdout] running 0 tests
[INFO] [stderr]      Running tests/all_tests.rs (/opt/rustwide/target/debug/deps/all_tests-603a7f1c4c4fee42)
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 568 tests
[INFO] [stdout] test combine_latest::combine_latest_composition_error_tests::test_combine_with_previous_then_combine_latest_propagates_error ... ok
[INFO] [stdout] test combine_latest::combine_latest_composition_error_tests::test_map_ordered_then_combine_latest_propagates_error ... ok
[INFO] [stdout] test combine_latest::combine_latest_composition_tests::test_fluxion_stream_combine_latest_composition ... ok
[INFO] [stdout] test combine_latest::combine_latest_error_tests::test_combine_latest_filter_predicate_continues_after_error ... ok
[INFO] [stdout] test combine_latest::combine_latest_composition_error_tests::test_filter_ordered_then_combine_latest_propagates_error ... ok
[INFO] [stdout] test combine_latest::combine_latest_error_tests::test_combine_latest_error_at_start ... ok
[INFO] [stdout] test combine_latest::combine_latest_error_tests::test_combine_latest_multiple_errors_from_different_streams ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_all_streams_have_published_different_order_emits_updates ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_different_stream_order_emits_consistent_results ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_empty_streams ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_secondary_closes_after_initial_emission_continues ... ok
[INFO] [stdout] test combine_latest::combine_latest_error_tests::test_combine_latest_propagates_error_from_primary_stream ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_with_identical_streams_emits_updates ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_all_streams_have_published_emits_updates ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_composition_error_tests::test_filter_ordered_then_combine_with_previous_propagates_error ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_composition_error_tests::test_map_ordered_then_combine_with_previous_propagates_error ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_composition_tests::test_combine_latest_combine_with_previous ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_composition_tests::test_complex_composition_ordered_merge_and_combine_with_previous ... ok
[INFO] [stdout] test combine_latest::combine_latest_error_tests::test_combine_latest_propagates_error_from_secondary_stream ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_composition_tests::test_take_latest_when_combine_with_previous ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_error_tests::test_combine_with_previous_error_at_first_item ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_error_tests::test_combine_with_previous_propagates_errors ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_error_tests::test_combine_with_previous_multiple_errors ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_error_tests::test_combine_with_previous_single_item_stream_with_error ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_error_tests::test_combine_with_previous_preserves_pairing_after_error ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_tests::test_combine_with_previous_for_types ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_tests::test_combine_with_previous_no_previous_value_emits ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_tests::test_combine_with_previous_single_previous_value ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_tests::test_combine_with_previous_boundary_maximum_concurrent_streams ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_tests::test_combine_with_previous_single_value_stream ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_tests::test_combine_with_previous_stream_ends ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_tests::test_combine_with_previous_boundary_empty_string_zero_values ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_composition_tests::test_combine_latest_with_distinct_until_changed_composition ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_composition_tests::test_distinct_until_changed_with_map_composition ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_composition_tests::test_distinct_until_changed_with_combine_with_previous_composition ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_composition_tests::test_filter_ordered_distinct_until_changed ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_error_tests::test_distinct_until_changed_error_at_start ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_error_tests::test_distinct_until_changed_error_only_stream ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_error_tests::test_distinct_until_changed_multiple_errors ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_tests::test_combine_with_previous_high_volume_sequential ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_error_tests::test_distinct_until_changed_alternating_errors_and_values ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_error_tests::test_distinct_until_changed_propagates_errors ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_error_tests::test_distinct_until_changed_error_between_duplicates ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_error_tests::test_distinct_until_changed_preserves_state_after_error ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_tests::test_distinct_until_changed_alternating ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_tests::test_distinct_until_changed_empty_stream ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_composition_tests::test_ordered_merge_combine_with_previous ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_tests::test_distinct_until_changed_single_value ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_tests::test_distinct_until_changed_fresh_timestamps ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_composition_error_tests::test_map_ordered_then_distinct_until_changed_by_propagates_error ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_tests::test_combine_with_previous_multiple_values ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_filter_rejects_initial_state ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_filter_function_panics - should panic ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_stream_closes_before_publish_no_output ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_error_tests::test_distinct_until_changed_by_alternating_errors_and_values ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_composition_error_tests::test_distinct_until_changed_error_propagation_in_composition ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_composition_tests::test_combine_latest_with_distinct_until_changed_composition ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_error_tests::test_distinct_until_changed_by_error_only_stream ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_composition_error_tests::test_distinct_until_changed_multiple_errors_in_composition ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_tests::test_distinct_until_changed_many_duplicates ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_error_tests::test_distinct_until_changed_by_propagates_errors ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_tests::test_distinct_until_changed_by_alternating ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_composition_tests::test_distinct_until_changed_by_with_combine_latest_composition ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_error_tests::test_distinct_until_changed_by_multiple_errors ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_tests::test_distinct_until_changed_by_empty_stream ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_composition_tests::test_distinct_until_changed_by_with_map_composition ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_error_tests::test_distinct_until_changed_by_error_at_start ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_not_all_streams_have_published_does_not_emit ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_tests::test_distinct_until_changed_by_single_value ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_error_tests::test_distinct_until_changed_by_preserves_state_after_error ... ok
[INFO] [stdout] test emit_when::emit_when_composition_error_tests::test_emit_when_propagates_error_from_mapped_trigger ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_tests::test_distinct_until_changed_basic ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_tests::test_distinct_until_changed_different_types ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_tests::test_distinct_until_changed_boolean_toggle ... ok
[INFO] [stdout] test distinct_until_changed::distinct_until_changed_tests::test_distinct_until_changed_with_filter_ordered ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_both_streams_have_errors ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_error_before_filter_ready ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_filter_returns_false_on_filter_update ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_filter_returns_false_on_source_update ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_multiple_filter_updates_no_source ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_predicate_continues_after_error ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_propagates_filter_error ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_propagates_source_error ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_source_none_on_filter_update ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_source_none_on_source_update ... ok
[INFO] [stdout] test emit_when::emit_when_error_tests::test_emit_when_alternating_false_conditions ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_composition_tests::test_distinct_until_changed_by_with_filter_composition ... ok
[INFO] [stdout] test combine_latest::combine_latest_tests::test_combine_latest_filter_alternates_between_true_false ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_error_tests::test_distinct_until_changed_by_custom_comparer_with_errors ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_error_tests::test_distinct_until_changed_by_error_between_duplicates ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_empty_streams ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_filter_compares_source_and_filter ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_filter_stream_closes ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_tests::test_distinct_until_changed_by_preserves_timestamps ... ok
[INFO] [stdout] test emit_when::emit_when_composition_error_tests::test_emit_when_propagates_error_from_scanned_source ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_filter_panics - should panic ... ok
[INFO] [stdout] test emit_when::emit_when_composition_tests::test_combine_with_previous_emit_when_map_ordered ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_both_values_required ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_source_stream_closes_after_filter ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_tests::test_distinct_until_changed_by_field_comparison ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_tests::test_distinct_until_changed_by_custom_logic ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_filter_stream_updates_trigger_reevaluation ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_tests::test_distinct_until_changed_by_many_duplicates ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_tests::test_distinct_until_changed_by_threshold ... ok
[INFO] [stdout] test emit_when::emit_when_composition_tests::test_ordered_merge_combine_with_previous_emit_when ... ok
[INFO] [stdout] test distinct_until_changed_by::distinct_until_changed_by_tests::test_distinct_until_changed_by_case_insensitive ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_threshold_comparison ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_composition_tests::test_combine_latest_filter_ordered ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_composition_tests::test_ordered_merge_filter_ordered ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_error_tests::test_filter_ordered_propagates_errors ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_age_threshold ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_error_tests::test_filter_ordered_all_filtered_except_error ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_all_filtered_out ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_alternating_pattern ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_basic_predicate ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_complex_predicate ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_empty_stream ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_multiple_types ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_none_filtered ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_preserves_ordering ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_single_item ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_tests::test_filter_ordered_with_pattern_matching ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_composition_error_tests::shared_error_propagates_through_chained_operators ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_composition_error_tests::shared_with_on_error_allows_selective_handling ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_composition_tests::shared_with_combine_with_previous_tracks_state_per_subscriber ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_composition_tests::shared_with_distinct_until_changed_tracks_state_per_subscriber ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_composition_tests::shared_with_filter_ordered_each_subscriber_filters_independently ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_composition_tests::shared_with_map_ordered_transforms_per_subscriber ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_error_tests::test_filter_ordered_chain_with_map_after_error ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_error_tests::test_filter_ordered_predicate_after_error ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_composition_tests::shared_with_transient_combine_latest_combines_subscribers ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_composition_tests::shared_with_transient_filtered_combine_latest_combines_subscribers ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_composition_tests::shared_with_mixed_combine_latest_combines_subscribers ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_composition_tests::shared_with_scan_ordered_accumulates_per_subscriber ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_error_tests::shared_propagates_error_and_closes_all_subscribers ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_error_tests::shared_multiple_errors_propagate_in_order ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::drop_closes_subject_and_cancels_task ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_error_tests::shared_error_from_source_operator_propagates_to_subscribers ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_composition_error_tests::test_distinct_until_changed_by_multiple_errors_in_composition ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::each_subscriber_can_chain_independently ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_complex_multi_condition ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::empty_source_stream_completes_subscribers_immediately ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::is_closed_reflects_state ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_error_tests::test_filter_ordered_error_at_start ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::late_subscriber_does_not_receive_past_items ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::high_subscriber_count_broadcasts_correctly ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::share_completes_subscribers_when_source_completes ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::subscribe_after_close_returns_error ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::source_operators_run_once_per_emission ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::subscriber_count_tracks_active_subscribers ... ok
[INFO] [stdout] test fluxion_subject::composition_error_tests::subject_at_end_forwarding_chain_propagates_error ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::share_broadcasts_to_multiple_subscribers ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::subscriber_dropped_mid_stream_does_not_affect_others ... ok
[INFO] [stdout] test fluxion_subject::composition_error_tests::subject_at_start_complex_chain_propagates_error ... ok
[INFO] [stdout] test fluxion_shared::fluxion_shared_tests::share_propagates_errors_to_all_subscribers ... ok
[INFO] [stdout] test combine_with_previous::combine_with_previous_composition_tests::test_filter_ordered_combine_with_previous ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_delta_based_filtering ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_multiple_source_updates_with_comparison ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_name_length_comparison ... ok
[INFO] [stdout] test fluxion_subject::composition_error_tests::subject_in_middle_gate_error_terminates_stream ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_chain_with_filter_and_map ... ok
[INFO] [stdout] test fluxion_subject::composition_error_tests::subject_on_error_with_ordered_merge_skips_transient ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_combined_with_stream_via_combine_latest ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_ordered_merge_distinct_by_species ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_combines_with_latest_from ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_combine_latest_then_take_items_limits_output ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_merge_with_stateful_height_bonus ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_skip_items_with_latest_from_ignores_prelude ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_start_with_take_items_preserves_temporal_merge ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_with_previous_computes_age_deltas ... ok
[INFO] [stdout] test map_ordered::map_ordered_composition_error_tests::test_multiple_errors_through_composition ... ok
[INFO] [stdout] test map_ordered::map_ordered_composition_error_tests::test_scan_ordered_error_propagation_with_map ... ok
[INFO] [stdout] test map_ordered::map_ordered_composition_tests::test_combine_with_previous_map_ordered ... ok
[INFO] [stdout] test map_ordered::map_ordered_composition_tests::test_combine_with_previous_map_ordered_filter_age_change ... ok
[INFO] [stdout] test map_ordered::map_ordered_composition_tests::test_combine_latest_combine_with_previous_map_ordered ... ok
[INFO] [stdout] test map_ordered::map_ordered_composition_tests::test_combine_with_previous_map_ordered_to_struct ... ok
[INFO] [stdout] test map_ordered::map_ordered_composition_tests::test_ordered_merge_combine_with_previous_map_ordered ... ok
[INFO] [stdout] test map_ordered::map_ordered_composition_tests::test_triple_ordered_merge_combine_with_previous_map_ordered ... ok
[INFO] [stdout] test map_ordered::map_ordered_error_tests::test_map_ordered_preserves_error_passthrough ... ok
[INFO] [stdout] test map_ordered::map_ordered_error_tests::test_map_ordered_chain_after_error ... ok
[INFO] [stdout] test map_ordered::map_ordered_error_tests::test_map_ordered_propagates_errors ... ok
[INFO] [stdout] test map_ordered::map_ordered_tests::test_map_ordered_basic_transformation ... ok
[INFO] [stdout] test map_ordered::map_ordered_tests::test_map_ordered_boolean_logic ... ok
[INFO] [stdout] test map_ordered::map_ordered_error_tests::test_map_ordered_transformation_after_error ... ok
[INFO] [stdout] test map_ordered::map_ordered_tests::test_map_ordered_empty_stream ... ok
[INFO] [stdout] test map_ordered::map_ordered_tests::test_map_ordered_multiple_transformations ... ok
[INFO] [stdout] test map_ordered::map_ordered_tests::test_map_ordered_preserves_ordering ... ok
[INFO] [stdout] test map_ordered::map_ordered_tests::test_map_ordered_extract_age_difference ... ok
[INFO] [stdout] test map_ordered::map_ordered_tests::test_map_ordered_single_value ... ok
[INFO] [stdout] test map_ordered::map_ordered_tests::test_map_ordered_to_struct ... ok
[INFO] [stdout] test map_ordered::map_ordered_tests::test_map_ordered_with_complex_closure ... ok
[INFO] [stdout] test merge_with::merge_with_composition_error_tests::test_merge_with_multiple_streams_error ... ok
[INFO] [stdout] test merge_with::merge_with_composition_tests::test_merge_with_chaining_multiple_operators_map_ordered ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_scan_and_distinct_detects_unique_leg_totals ... ok
[INFO] [stdout] test merge_with::merge_with_error_tests::test_merge_with_errors_interleaved_with_values ... ok
[INFO] [stdout] test merge_with::merge_with_error_tests::test_merge_with_into_fluxion_stream_error_handling ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_cross_type_comparison ... ok
[INFO] [stdout] test merge_with::merge_with_error_tests::test_merge_with_multiple_streams_error_filtering ... ok
[INFO] [stdout] test merge_with::merge_with_error_tests::test_merge_with_propagates_errors_from_first_stream ... ok
[INFO] [stdout] test merge_with::merge_with_error_tests::test_merge_with_state_preserved_despite_filtered_errors ... ok
[INFO] [stdout] test merge_with::merge_with_error_tests::test_merge_with_three_streams_with_filtered_errors ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_clone_closure ... ok
[INFO] [stdout] test merge_with::merge_with_composition_tests::test_merge_with_chaining_map_ordered ... ok
[INFO] [stdout] test merge_with::merge_with_error_tests::test_merge_with_empty_stream_with_only_errors ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_empty_streams ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_hybrid_using_repository_emits ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_into_fluxion_stream_empty ... ok
[INFO] [stdout] test merge_with::merge_with_error_tests::test_merge_with_poll_pending_simulation ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_into_fluxion_stream_standalone ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_mixed_empty_and_non_empty_streams ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_parallel_processing ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_similar_streams_emits ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_state_mutation_complex ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_timestamp_ordering_preserved ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_single_stream_interleaved_emissions ... ok
[INFO] [stdout] test merge_with::merge_with_error_tests::test_merge_with_error_at_start_filtered ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_user_closure_panics - should panic ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_at_start_map_and_filter ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_in_middle_take_latest_when ... ok
[INFO] [stdout] test emit_when::emit_when_tests::test_emit_when_stateful_comparison ... ok
[INFO] [stdout] test map_ordered::map_ordered_composition_error_tests::test_error_propagation_through_multiple_operators ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_composition_error_tests::test_scan_ordered_error_propagation_with_filter ... ok
[INFO] [stdout] test merge_with::merge_with_tests::test_merge_with_large_streams_emits ... ok
[INFO] [stdout] test on_error::on_error_composition_error_tests::test_on_error_handles_errors_from_combine_latest ... ok
[INFO] [stdout] test merge_with::merge_with_error_tests::test_merge_with_error_before_stream_ends ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_as_filter_for_emit_when ... ok
[INFO] [stdout] test on_error::on_error_composition_error_tests::test_on_error_empty_pipeline_with_errors ... ok
[INFO] [stdout] test on_error::on_error_composition_error_tests::test_on_error_with_combine_with_previous_maintains_previous_value ... ok
[INFO] [stdout] test fluxion_subject::composition_tests::subject_take_while_with_stops_on_short_plants ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_handler_never_consumes ... ok
[INFO] [stdout] test on_error::on_error_composition_error_tests::test_on_error_before_ordered_merge_handles_individual_stream_errors ... ok
[INFO] [stdout] test on_error::on_error_composition_error_tests::test_on_error_handles_errors_from_ordered_merge ... ok
[INFO] [stdout] test on_error::on_error_composition_error_tests::test_on_error_selective_handling_in_composed_pipeline ... ok
[INFO] [stdout] test on_error::on_error_composition_error_tests::test_on_error_with_scan_ordered_preserves_accumulator_state ... ok
[INFO] [stdout] test on_error::on_error_composition_error_tests::test_on_error_handles_rapid_consecutive_errors_in_pipeline ... ok
[INFO] [stdout] test on_error::on_error_composition_error_tests::test_on_error_propagation_stops_at_first_handler ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_handler_preserves_error_details_on_propagate ... ok
[INFO] [stdout] test on_error::on_error_composition_error_tests::test_on_error_handles_errors_from_take_latest_when ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_handler_alternating_decision ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_handler_receives_correct_error_type ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_handler_tracks_error_history ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_handler_decision_based_on_error_content ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_empty_stream ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_handler_with_counter_state ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_conditional_based_on_error_content ... ok
[INFO] [stdout] test on_error::on_error_composition_tests::test_on_error_chain_of_responsibility ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_handler_with_rate_limiting_behavior ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_propagates_all_errors ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_handler_with_external_flag ... ok
[INFO] [stdout] test on_error::on_error_composition_tests::test_on_error_in_middle_of_chain ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_rapid_error_sequence ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_error_tests::test_filter_then_ordered_merge_with_errors ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_error_tests::test_ordered_merge_chained_with_errors ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_error_tests::test_ordered_merge_error_after_filter ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_error_tests::test_ordered_merge_error_preserves_timestamp_through_pipeline ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_error_tests::test_ordered_merge_errors_only_through_filter ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_error_tests::test_ordered_merge_map_filter_chain_with_errors ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_error_tests::test_ordered_merge_multiple_errors_through_map ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_error_tests::test_ordered_merge_then_filter_with_errors ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_error_tests::test_ordered_merge_then_map_with_errors ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_consumes_all_errors ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_handler_always_consumes ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_filter_then_ordered_merge ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_map_then_ordered_merge ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_ordered_merge_empty_after_filter ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_ordered_merge_filter_map_chain ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_ordered_merge_mixed_testdata_then_filter ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_ordered_merge_preserves_ordering_through_map ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_ordered_merge_then_filter ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_ordered_merge_then_map ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_ordered_merge_then_ordered_merge ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_ordered_merge_three_streams_with_filter ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_ordered_merge_with_complex_pipeline ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_error_tests::test_ordered_merge_three_streams_filter_map_errors ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_error_tests::test_ordered_merge_consecutive_errors_same_stream ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_error_tests::test_ordered_merge_continues_after_multiple_errors ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_error_tests::test_ordered_merge_error_at_start ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_error_tests::test_ordered_merge_error_before_stream_ends ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_error_tests::test_ordered_merge_error_ordering_by_timestamp ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_error_tests::test_ordered_merge_multiple_errors_from_different_streams ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_error_tests::test_ordered_merge_propagates_error_from_first_stream ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_error_tests::test_ordered_merge_propagates_error_from_second_stream ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_error_tests::test_ordered_merge_three_streams_with_errors ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_error_tests::test_ordered_merge_only_errors_no_values ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_duplicate_timestamps ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_empty_streams ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_ends_when_all_closed ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_large_volume ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_mixed_types_in_enum ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_multiple_streams ... ok
[INFO] [stdout] test on_error::on_error_error_tests::test_on_error_multiple_errors_same_message ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_chain_of_responsibility ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_preserves_timestamp_metadata ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_one_stream_closes_early ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_preserves_value_order ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_composition_tests::test_ordered_merge_map_preserves_timestamps ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_timestamp_ordering ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_does_not_wait_for_all_streams ... ok
[INFO] [stdout] test ordered_merge::ordered_merge_tests::test_ordered_merge_parallel_sends ... ok
[INFO] [stdout] test partition::partition_composition_error_tests::test_map_then_partition_error_propagation ... ok
[INFO] [stdout] test partition::partition_composition_error_tests::test_partition_then_map_ordered_error_propagation ... ok
[INFO] [stdout] test partition::partition_composition_error_tests::test_partition_then_scan_ordered_error_propagation ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_partial_chain ... ok
[INFO] [stdout] test partition::partition_composition_error_tests::test_filter_then_partition_error_propagation ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_filter_ordered_then_partition ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_map_ordered_then_partition ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_then_distinct_until_changed ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_then_combine_with_previous ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_then_filter_ordered ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_share_then_combine_latest ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_then_map_ordered ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_then_skip_items ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_then_ordered_merge ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_then_scan_ordered ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_then_take_items ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_with_subject_and_filter ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_share_then_partition ... ok
[INFO] [stdout] test partition::partition_error_tests::test_partition_error_after_values ... ok
[INFO] [stdout] test partition::partition_error_tests::test_partition_error_message_preserved ... ok
[INFO] [stdout] test partition::partition_error_tests::test_partition_mixed_values_and_error ... ok
[INFO] [stdout] test partition::partition_composition_error_tests::test_partition_then_filter_ordered_error_propagation ... ok
[INFO] [stdout] test partition::partition_error_tests::test_partition_propagates_error_to_both_streams ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_all_to_false ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_age_threshold ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_all_to_true ... ok
[INFO] [stdout] test partition::partition_error_tests::test_partition_error_terminates_routing ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_basic_predicate ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_by_animal_legs ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_by_type ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_completes_both_on_close ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_drop_one_stream_early ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_empty_stream ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_multiple_types_complex ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_plant_height_threshold ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_error_tests::test_chained_sample_ratios_with_errors ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_error_tests::test_complex_pipeline_with_multiple_errors ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_error_tests::test_sample_ratio_after_filter_ordered_with_errors ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_error_tests::test_sample_ratio_before_filter_ordered_with_errors ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_error_tests::test_sample_ratio_error_preserves_through_composition ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_error_tests::test_sample_ratio_with_map_ordered_and_errors ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_error_tests::test_sample_ratio_zero_still_passes_errors_in_composition ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_tests::test_chained_sample_ratios ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_tests::test_sample_ratio_after_filter_ordered ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_tests::test_sample_ratio_after_map_ordered ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_tests::test_sample_ratio_before_filter_ordered ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_tests::test_sample_ratio_before_map_ordered ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_tests::test_sample_ratio_complex_pipeline ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_then_combine_latest ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_only_errors_stream ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_drop_both_streams_gracefully ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_error_tests::test_sample_ratio_interleaved_errors_and_values ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_error_tests::test_sample_ratio_error_preserves_message ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_error_tests::test_sample_ratio_multiple_errors_pass_through ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_error_tests::test_sample_ratio_passes_through_errors_with_ratio_zero ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_selective_by_message_content ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_with_side_effects ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_continues_after_consumed_error ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_tests::test_sample_ratio_one_emits_all ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_tests::test_sample_ratio_panics_on_greater_than_one - should panic ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_tests::test_sample_ratio_panics_on_negative - should panic ... ok
[INFO] [stdout] test partition::partition_composition_error_tests::test_partition_error_terminates_downstream_chains ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_tests::test_sample_ratio_send_dropped_empty_stream ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_tests::test_sample_ratio_preserves_item_order ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_composition_error_tests::test_chained_scan_ordered_error_propagation ... ok
[INFO] [stdout] test partition::partition_composition_tests::test_partition_then_with_latest_from ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_composition_error_tests::test_map_ordered_error_propagation_into_scan_ordered ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_composition_tests::test_combine_latest_scan_ordered_total_age ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_composition_tests::test_ordered_merge_scan_ordered_name_change ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_composition_tests::test_scan_ordered_chained ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_composition_tests::test_scan_ordered_composed_with_map_ordered ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_error_tests::test_scan_ordered_alternating_values_and_errors ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_error_tests::test_scan_ordered_error_at_start ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_error_tests::test_scan_ordered_error_between_values ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_error_tests::test_scan_ordered_error_doesnt_reset_complex_state ... ok
[INFO] [stdout] test partition::partition_tests::test_partition_preserves_temporal_order ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_error_tests::test_scan_ordered_error_with_string_accumulation ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_error_tests::test_sample_ratio_passes_through_errors_with_ratio_one ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_error_tests::test_scan_ordered_error_with_type_transformation ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_error_tests::test_scan_ordered_multiple_consecutive_errors ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_error_tests::test_scan_ordered_propagates_errors ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_average_age ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_build_roster ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_collect_names ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_error_tests::test_scan_ordered_only_errors ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_composition_tests::test_merge_with_chaining_filter_ordered ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_empty_stream ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_count_people ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_format_summary ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_multiple_people ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_single_element ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_timestamp_preservation ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_total_age ... ok
[INFO] [stdout] test skip_items::skip_items_composition_tests::test_map_ordered_skip_items ... ok
[INFO] [stdout] test skip_items::skip_items_error_tests::test_skip_counts_errors_as_items ... ok
[INFO] [stdout] test skip_items::skip_items_composition_tests::test_ordered_merge_then_skip_items ... ok
[INFO] [stdout] test skip_items::skip_items_error_tests::test_skip_propagates_errors ... ok
[INFO] [stdout] test skip_items::skip_items_tests::test_skip_more_than_available ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_tests::test_scan_ordered_min_max_age ... ok
[INFO] [stdout] test skip_items::skip_items_tests::test_skip_skips_initial_items ... ok
[INFO] [stdout] test start_with::start_with_composition_error_tests::test_map_ordered_then_start_with_propagates_error ... ok
[INFO] [stdout] test start_with::start_with_composition_tests::test_ordered_merge_then_start_with ... ok
[INFO] [stdout] test start_with::start_with_composition_tests::test_combine_with_previous_start_with ... ok
[INFO] [stdout] test start_with::start_with_error_tests::test_start_with_propagates_errors_from_initial_values ... ok
[INFO] [stdout] test start_with::start_with_error_tests::test_start_with_propagates_errors_from_source_stream ... ok
[INFO] [stdout] test start_with::start_with_tests::test_start_with_empty_initial_values ... ok
[INFO] [stdout] test start_with::start_with_tests::test_start_with_prepends_initial_values ... ok
[INFO] [stdout] test take_items::take_items_composition_error_tests::test_map_ordered_then_take_items_propagates_error ... ok
[INFO] [stdout] test take_items::take_items_composition_tests::test_map_ordered_then_take_items ... ok
[INFO] [stdout] test take_items::take_items_composition_tests::test_skip_items_then_take_items ... ok
[INFO] [stdout] test take_items::take_items_composition_tests::test_start_with_skip_items_take_items ... ok
[INFO] [stdout] test take_items::take_items_composition_tests::test_start_with_then_take_items ... ok
[INFO] [stdout] test take_items::take_items_error_tests::test_take_counts_errors_as_items ... ok
[INFO] [stdout] test take_items::take_items_composition_tests::test_with_latest_from_then_take_items ... ok
[INFO] [stdout] test take_items::take_items_tests::test_take_limits_items ... ok
[INFO] [stdout] test take_items::take_items_tests::test_take_zero_items ... ok
[INFO] [stdout] test take_items::take_items_error_tests::test_take_propagates_errors ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_three_level_chain ... ok
[INFO] [stdout] test scan_ordered::scan_ordered_composition_error_tests::test_filter_ordered_error_propagation_into_scan_ordered ... ok
[INFO] [stdout] test filter_ordered::filter_ordered_composition_tests::test_scan_ordered_composed_with_filter ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_tests::test_sample_ratio_maintains_determinism_in_composition ... ok
[INFO] [stdout] test skip_items::skip_items_composition_error_tests::test_map_ordered_then_skip_items_propagates_error ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_composition_tests::test_filter_ordered_take_latest_when ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_error_before_any_trigger ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_composition_error_tests::test_take_latest_when_propagates_error_from_filtered_trigger ... ok
[INFO] [stdout] test map_ordered::map_ordered_composition_tests::test_filter_ordered_map_ordered ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_composition_error_tests::test_take_latest_when_propagates_error_from_mapped_source ... ok
[INFO] [stdout] test on_error::on_error_tests::test_on_error_multiple_consecutive_errors ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_tests::test_sample_ratio_different_seeds_produce_different_results ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_tests::test_sample_ratio_deterministic_with_same_seed ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_source_overwritten_between_triggers ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_propagates_source_error ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_composition_tests::test_combine_latest_take_latest_when ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_boundary_maximum_concurrent_streams ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_composition_tests::test_ordered_merge_take_latest_when ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_empty_streams ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_composition_error_tests::test_take_latest_when_complex_chain_with_scan_and_map ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_filter_returns_false ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_filter_panics - should panic ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_filter_satisfied_emits ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_source_updates_dont_emit ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_boundary_empty_string_zero_values ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_multiple_emissions_filter_satisfied ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_alternating_filter_conditions ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_multiple_triggers_no_source ... ok
[INFO] [stdout] test take_while_with::take_while_with_composition_error_tests::test_take_while_with_error_propagation_at_end_of_chain ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_filter_not_satisfied_does_not_emit ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_trigger_before_source ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_multiple_emissions_filter_not_satisfied ... ok
[INFO] [stdout] test take_while_with::take_while_with_composition_tests::test_ordered_merge_filter_ordered_take_while_with ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_composition_tests::test_chained_sample_ratios_zero_in_chain ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_error_tests::test_sample_ratio_error_on_empty_stream ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_filter_stream_closes_no_further_emits ... ok
[INFO] [stdout] test take_while_with::take_while_with_composition_tests::test_combine_latest_take_while_with ... ok
[INFO] [stdout] test take_while_with::take_while_with_error_tests::test_take_while_with_error_recovery ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_filter_toggle_emissions ... ok
[INFO] [stdout] test take_while_with::take_while_with_composition_tests::test_combine_with_previous_map_ordered_take_while_with_age_difference ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_tests::test_sample_ratio_zero_emits_nothing ... ok
[INFO] [stdout] test take_while_with::take_while_with_composition_tests::test_filter_ordered_map_ordered_combine_with_previous_take_while_with ... ok
[INFO] [stdout] test take_while_with::take_while_with_composition_tests::test_ordered_merge_take_while_with ... ok
[INFO] [stdout] test sample_ratio::sample_ratio_tests::test_sample_ratio_boundary_values ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_empty_source ... ok
[INFO] [stdout] test take_while_with::take_while_with_composition_tests::test_take_latest_when_take_while_with ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_source_publishes_before_filter ... ok
[INFO] [stdout] test take_while_with::take_while_with_error_tests::test_take_while_with_error_at_start ... ok
[INFO] [stdout] test take_while_with::take_while_with_error_tests::test_take_while_with_predicate_after_error ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_always_true ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_filer_unset ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_with_alternating_filter_values ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_buffer_does_not_grow_unbounded ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_filter_updates_without_source ... ok
[INFO] [stdout] test take_while_with::take_while_with_error_tests::test_take_while_with_filter_error_at_start ... ok
[INFO] [stdout] test tap::tap_composition_error_tests::test_chained_taps_with_errors ... ok
[INFO] [stdout] test tap::tap_composition_error_tests::test_complex_pipeline_with_multiple_errors ... ok
[INFO] [stdout] test tap::tap_composition_error_tests::test_tap_after_filter_ordered_with_errors ... ok
[INFO] [stdout] test tap::tap_composition_error_tests::test_tap_before_filter_ordered_with_errors ... ok
[INFO] [stdout] test tap::tap_composition_error_tests::test_tap_error_preserves_through_composition ... ok
[INFO] [stdout] test take_while_with::take_while_with_error_tests::test_take_while_with_propagates_filter_error ... ok
[INFO] [stdout] test tap::tap_composition_tests::test_multiple_taps_in_pipeline ... ok
[INFO] [stdout] test tap::tap_composition_tests::test_tap_after_filter_ordered ... ok
[INFO] [stdout] test tap::tap_composition_error_tests::test_tap_with_map_ordered_and_errors ... ok
[INFO] [stdout] test tap::tap_composition_tests::test_tap_after_map_ordered ... ok
[INFO] [stdout] test tap::tap_composition_tests::test_tap_before_map_ordered ... ok
[INFO] [stdout] test tap::tap_composition_tests::test_tap_before_filter_ordered ... ok
[INFO] [stdout] test tap::tap_composition_tests::test_tap_chained_taps ... ok
[INFO] [stdout] test tap::tap_composition_tests::test_tap_complex_pipeline ... ok
[INFO] [stdout] test tap::tap_error_tests::test_tap_error_preserves_message ... ok
[INFO] [stdout] test tap::tap_error_tests::test_tap_interleaved_values_and_errors ... ok
[INFO] [stdout] test tap::tap_error_tests::test_tap_multiple_errors_pass_through ... ok
[INFO] [stdout] test tap::tap_error_tests::test_tap_not_called_for_errors ... ok
[INFO] [stdout] test tap::tap_error_tests::test_tap_only_errors ... ok
[INFO] [stdout] test tap::tap_error_tests::test_tap_passes_through_errors ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_complex_predicate ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_multiple_source_items_same_filter ... ok
[INFO] [stdout] test tap::tap_tests::test_tap_multiple_types ... ok
[INFO] [stdout] test tap::tap_tests::test_tap_maintains_order ... ok
[INFO] [stdout] test tap::tap_tests::test_tap_receives_correct_values ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_with_filter_false_on_first_source ... ok
[INFO] [stdout] test tap::tap_tests::test_tap_values_pass_through_unchanged ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_error_tests::test_chained_window_by_count_propagates_error ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_error_tests::test_filter_ordered_then_window_by_count_propagates_error ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_error_tests::test_map_ordered_identity_then_window_by_count_propagates_error ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_error_tests::test_map_ordered_then_window_by_count_propagates_error ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_error_tests::test_window_by_count_then_filter_ordered_propagates_error ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_error_tests::test_window_by_count_then_map_ordered_propagates_error ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_error_tests::test_window_by_count_with_combine_with_previous_propagates_error ... ok
[INFO] [stdout] test tap::tap_tests::test_tap_side_effect_called_for_each_value ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_tests::test_filter_ordered_then_window_by_count ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_tests::test_map_ordered_then_window_by_count ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_tests::test_window_by_count_chain_different_sizes ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_error_tests::test_window_by_count_with_test_data_propagates_error ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_tests::test_window_by_count_preserves_timestamp_ordering ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_tests::test_window_by_count_then_map_ordered ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_tests::test_window_by_count_with_combine_with_previous ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_tests::test_window_by_count_with_map_extracts_first ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_tests::test_window_by_count_with_tap ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_with_filter_updates_then_source ... ok
[INFO] [stdout] test window_by_count::window_by_count_error_tests::test_window_by_count_error_at_window_boundary ... ok
[INFO] [stdout] test window_by_count::window_by_count_error_tests::test_window_by_count_error_clears_partial_window ... ok
[INFO] [stdout] test window_by_count::window_by_count_error_tests::test_window_by_count_error_preserves_error_details ... ok
[INFO] [stdout] test window_by_count::window_by_count_error_tests::test_window_by_count_multiple_errors ... ok
[INFO] [stdout] test window_by_count::window_by_count_error_tests::test_window_by_count_partial_after_error_on_close ... ok
[INFO] [stdout] test window_by_count::window_by_count_error_tests::test_window_by_count_propagates_error ... ok
[INFO] [stdout] test window_by_count::window_by_count_error_tests::test_window_by_count_stream_ends_after_error ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_both_streams_have_errors ... ok
[INFO] [stdout] test tap::tap_tests::test_tap_preserves_timestamps ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_empty_stream_no_output ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_interleaved_updates ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_mixed_types ... ok
[INFO] [stdout] test tap::tap_composition_tests::test_tap_with_filter_that_blocks_all ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_basic ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_partial_timestamp_from_last ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_size_one ... ok
[INFO] [stdout] test window_by_count::window_by_count_composition_tests::test_window_by_count_then_filter_ordered ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_zero_panics - should panic ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_composition_error_tests::test_with_latest_from_error_propagation_at_end_of_chain ... ok
[INFO] [stdout] test window_by_count::window_by_count_error_tests::test_window_by_count_continues_after_error ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_composition_tests::test_ordered_merge_into_with_latest_from ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_composition_tests::test_take_latest_when_with_latest_from_custom_selector ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_composition_tests::test_with_latest_from_composition_end_of_chain ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_error_tests::test_with_latest_from_error_before_secondary_ready ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_with_source_before_filter ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_emits_partial_on_completion ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_multiple_complete_windows ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_tests::test_with_latest_from_basic ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_tests::test_with_latest_from_both_streams_close_before_emission ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_tests::test_with_latest_from_custom_selector ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_tests::test_with_latest_from_large_number_of_emissions ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_tests::test_with_latest_from_multiple_concurrent_streams ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_tests::test_take_latest_when_multiple_source_updates_while_filter_false ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_tests::test_with_latest_from_primary_completes_early ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_composition_tests::test_filter_ordered_with_latest_from ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_tests::test_with_latest_from_secondary_emits_first_no_output ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_tests::test_with_latest_from_secondary_updates_latest ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_tests::test_with_latest_from_secondary_completes_early ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_error_tests::test_with_latest_from_propagates_primary_error ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_emits_complete_windows ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_no_emission_until_complete ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_timestamp_from_last_item ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_error_tests::test_with_latest_from_propagates_secondary_error ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_error_tests::test_with_latest_from_selector_continues_after_error ... ok
[INFO] [stdout] test take_while_with::take_while_with_error_tests::test_take_while_with_propagates_source_error ... ok
[INFO] [stdout] test with_latest_from::with_latest_from_tests::test_with_latest_from_ordering_preserved ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_filter_predicate_after_error ... ok
[INFO] [stdout] test take_latest_when::take_latest_when_error_tests::test_take_latest_when_propagates_trigger_error ... ok
[INFO] [stdout] test tap::tap_tests::test_tap_empty_stream ... ok
[INFO] [stdout] test window_by_count::window_by_count_tests::test_window_large_size ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_filter_changes_back_to_true ... ok
[INFO] [stdout] test take_while_with::take_while_with_tests::test_take_while_with_already_terminated ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 568 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 3.04s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/into_fluxion_stream_tests.rs (/opt/rustwide/target/debug/deps/into_fluxion_stream_tests-3b37b8b9e5ac7979)
[INFO] [stdout] 
[INFO] [stdout] running 11 tests
[INFO] [stdout] test no_coverage_helpers::tests::fake_test_to_trick_tarpaulin ... ok
[INFO] [stdout] test test_into_fluxion_stream_no_map ... ok
[INFO] [stdout] test test_into_fluxion_stream_empty_channel ... ok
[INFO] [stdout] test test_into_fluxion_stream_transformation_logic ... ok
[INFO] [stdout] test test_two_heterogeneous_streams_packed_into_enum ... ok
[INFO] [stdout] test test_into_fluxion_stream_late_sends ... ok
[INFO] [stdout] test test_into_fluxion_stream_can_combine_with_other_streams ... ok
[INFO] [stdout] test test_into_fluxion_stream_multiple_items ... ok
[INFO] [stdout] test test_into_fluxion_stream_preserves_order ... ok
[INFO] [stdout] test test_into_fluxion_stream_basic_transformation ... ok
[INFO] [stdout] test test_into_fluxion_stream_high_volume ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 11 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.11s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/types_tests.rs (/opt/rustwide/target/debug/deps/types_tests-91b965652aa39b8e)
[INFO] [stdout] 
[INFO] [stdout] running 36 tests
[INFO] [stdout] test test_combined_state_clone ... ok
[INFO] [stdout] test test_combined_state_is_empty_false ... ok
[INFO] [stdout] test test_combined_state_debug ... ok
[INFO] [stdout] test test_combined_state_is_empty_true ... ok
[INFO] [stdout] test test_combined_state_len ... ok
[INFO] [stdout] test test_combined_state_large_vector ... ok
[INFO] [stdout] test test_combined_state_mutation_through_with_previous ... ok
[INFO] [stdout] test test_combined_state_new ... ok
[INFO] [stdout] test test_combined_state_ord ... ok
[INFO] [stdout] test test_combined_state_new_empty ... ok
[INFO] [stdout] test test_combined_state_single_element ... ok
[INFO] [stdout] test test_combined_state_timestamped_into_inner ... ok
[INFO] [stdout] test test_combined_state_timestamped_with_timestamp ... ok
[INFO] [stdout] test test_combined_state_timestamped_timestamp ... ok
[INFO] [stdout] test test_combined_state_partial_eq ... ok
[INFO] [stdout] test test_combined_state_values ... ok
[INFO] [stdout] test test_timestamped_trait_bounds_compile ... ok
[INFO] [stdout] test test_with_previous_as_pair_none ... ok
[INFO] [stdout] test test_combined_state_with_complex_types ... ok
[INFO] [stdout] test test_with_previous_as_pair_some ... ok
[INFO] [stdout] test test_with_previous_new_no_previous ... ok
[INFO] [stdout] test test_with_previous_clone ... ok
[INFO] [stdout] test test_with_previous_combined_state_timestamp ... ok
[INFO] [stdout] test test_with_previous_ord ... ok
[INFO] [stdout] test test_with_previous_partial_eq ... ok
[INFO] [stdout] test test_with_previous_containing_combined_state ... ok
[INFO] [stdout] test test_with_previous_same_values ... ok
[INFO] [stdout] test test_with_previous_string_types ... ok
[INFO] [stdout] test test_with_previous_debug ... ok
[INFO] [stdout] test test_with_previous_has_previous_false ... ok
[INFO] [stdout] test test_with_previous_has_previous_true ... ok
[INFO] [stdout] test test_with_previous_new ... ok
[INFO] [stdout] test test_with_previous_timestamped_into_inner ... ok
[INFO] [stdout] test test_with_previous_timestamped_with_timestamp ... ok
[INFO] [stdout] test test_with_previous_timestamped_timestamp ... ok
[INFO] [stdout] test test_combined_state_len_empty ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 36 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s
[INFO] [stdout] 
[INFO] [stderr]    Doc-tests fluxion_stream
[INFO] [stdout] 
[INFO] [stdout] running 50 tests
[INFO] [stdout] test src/combine_with_previous/mod.rs - combine_with_previous (line 40) ... ok
[INFO] [stdout] test src/emit_when/mod.rs - emit_when (line 20) ... ok
[INFO] [stdout] test src/lib.rs - (line 206) ... ok
[INFO] [stdout] test src/lib.rs - (line 235) ... ok
[INFO] [stdout] test src/lib.rs - (line 260) ... ok
[INFO] [stdout] test src/combine_latest/mod.rs - combine_latest (line 20) ... ok
[INFO] [stdout] test src/distinct_until_changed/mod.rs - distinct_until_changed::implementation (line 24) ... ok
[INFO] [stdout] test src/distinct_until_changed_by/mod.rs - distinct_until_changed_by::implementation (line 68) ... ok
[INFO] [stdout] test src/filter_ordered/mod.rs - filter_ordered::implementation (line 29) ... ok
[INFO] [stdout] test src/distinct_until_changed_by/mod.rs - distinct_until_changed_by::implementation (line 94) ... ok
[INFO] [stdout] test src/into_fluxion_stream/multi_threaded.rs - into_fluxion_stream::multi_threaded::IntoFluxionStream::into_fluxion_stream (line 11) ... ok
[INFO] [stdout] test src/distinct_until_changed/mod.rs - distinct_until_changed::implementation (line 85) ... ok
[INFO] [stdout] test src/distinct_until_changed/mod.rs - distinct_until_changed::implementation (line 56) ... ok
[INFO] [stdout] test src/lib.rs - (line 470) ... ok
[INFO] [stdout] test src/merge_with/multi_threaded.rs - merge_with::multi_threaded::MergedStream<Empty<StreamItem<()>>,State,()>::seed (line 11) - compile ... ok
[INFO] [stdout] test src/distinct_until_changed_by/mod.rs - distinct_until_changed_by::implementation (line 36) ... ok
[INFO] [stdout] test src/lib.rs - (line 294) ... ok
[INFO] [stdout] test src/prelude.rs - prelude (line 9) ... ignored
[INFO] [stdout] test src/lib.rs - (line 407) ... ok
[INFO] [stdout] test src/into_fluxion_stream/mod.rs - into_fluxion_stream (line 12) ... ok
[INFO] [stdout] test src/ordered_merge/mod.rs - ordered_merge (line 19) ... ok
[INFO] [stdout] test src/lib.rs - (line 500) ... ok
[INFO] [stdout] test src/map_ordered/mod.rs - map_ordered (line 20) ... ok
[INFO] [stdout] test src/lib.rs - (line 560) ... ok
[INFO] [stdout] test src/lib.rs - (line 379) ... ok
[INFO] [stdout] test src/into_fluxion_stream/mod.rs - into_fluxion_stream (line 27) ... ok
[INFO] [stdout] test src/lib.rs - (line 532) ... ok
[INFO] [stdout] test src/merge_with/mod.rs - merge_with (line 12) ... ok
[INFO] [stdout] test src/lib.rs - (line 432) ... ok
[INFO] [stdout] test src/partition/mod.rs - partition (line 45) ... ok
[INFO] [stdout] test src/on_error/mod.rs - on_error::implementation (line 24) ... ok
[INFO] [stdout] test src/scan_ordered/mod.rs - scan_ordered (line 79) ... ok
[INFO] [stdout] test src/lib.rs - (line 591) ... ok
[INFO] [stdout] test src/scan_ordered/mod.rs - scan_ordered (line 55) ... ok
[INFO] [stdout] test src/share/mod.rs - share (line 33) ... ok
[INFO] [stdout] test src/scan_ordered/mod.rs - scan_ordered (line 29) ... ok
[INFO] [stdout] test src/with_latest_from/mod.rs - with_latest_from (line 19) ... ok
[INFO] [stdout] test src/lib.rs - (line 70) ... ok
[INFO] [stdout] test src/sample_ratio/mod.rs - sample_ratio (line 58) - compile ... ok
[INFO] [stdout] test src/take_latest_when/mod.rs - take_latest_when (line 32) ... ok
[INFO] [stdout] test src/take_items/mod.rs - take_items (line 29) ... ok
[INFO] [stdout] test src/skip_items/mod.rs - skip_items (line 28) ... ok
[INFO] [stdout] test src/start_with/mod.rs - start_with (line 26) ... ok
[INFO] [stdout] test src/take_while_with/mod.rs - take_while_with (line 20) ... ok
[INFO] [stdout] test src/scan_ordered/mod.rs - scan_ordered (line 113) ... ok
[INFO] [stdout] test src/types.rs - types::CombinedState (line 76) ... ok
[INFO] [stdout] test src/sample_ratio/mod.rs - sample_ratio (line 19) ... ok
[INFO] [stdout] test src/tap/mod.rs - tap (line 18) ... ok
[INFO] [stdout] test src/tap/mod.rs - tap (line 44) ... ok
[INFO] [stdout] test src/window_by_count/mod.rs - window_by_count (line 18) ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 49 passed; 0 failed; 1 ignored; 0 measured; 0 filtered out; finished in 3.65s
[INFO] [stdout] 
[INFO] running `Command { std: "docker" "inspect" "73ece709c78a41166151c69ae1cf7f35922689bd2f371e6215a40849b55e4a06", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "73ece709c78a41166151c69ae1cf7f35922689bd2f371e6215a40849b55e4a06", kill_on_drop: false }`
[INFO] [stdout] 73ece709c78a41166151c69ae1cf7f35922689bd2f371e6215a40849b55e4a06
