[INFO] fetching crate rx_core 0.2.1... [INFO] testing rx_core-0.2.1 against try#dec9417b8611e34e787a3e4c37686b5131f9e5c5 for pr-154210-2 [INFO] extracting crate rx_core 0.2.1 into /workspace/builds/worker-2-tc2/source [INFO] started tweaking crates.io crate rx_core 0.2.1 [INFO] removed 0 missing examples [INFO] removed 0 missing tests [INFO] finished tweaking crates.io crate rx_core 0.2.1 [INFO] tweaked toml for crates.io crate rx_core 0.2.1 written to /workspace/builds/worker-2-tc2/source/Cargo.toml [INFO] validating manifest of crates.io crate rx_core 0.2.1 on toolchain dec9417b8611e34e787a3e4c37686b5131f9e5c5 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+dec9417b8611e34e787a3e4c37686b5131f9e5c5" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate crates.io crate rx_core 0.2.1 already has a lockfile, it will not be regenerated [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+dec9417b8611e34e787a3e4c37686b5131f9e5c5" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+dec9417b8611e34e787a3e4c37686b5131f9e5c5" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 27d0feb38dde8a4a6be8283b9052319739d2e83c6e8de7724237fd51e267aac1 [INFO] running `Command { std: "docker" "start" "-a" "27d0feb38dde8a4a6be8283b9052319739d2e83c6e8de7724237fd51e267aac1", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "27d0feb38dde8a4a6be8283b9052319739d2e83c6e8de7724237fd51e267aac1", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "27d0feb38dde8a4a6be8283b9052319739d2e83c6e8de7724237fd51e267aac1", kill_on_drop: false }` [INFO] [stdout] 27d0feb38dde8a4a6be8283b9052319739d2e83c6e8de7724237fd51e267aac1 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+dec9417b8611e34e787a3e4c37686b5131f9e5c5" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] b466aa9735cd43640f7d42a045af2319dbd05bb45d4d1c1f3e0ff90c62bec9c6 [INFO] running `Command { std: "docker" "start" "-a" "b466aa9735cd43640f7d42a045af2319dbd05bb45d4d1c1f3e0ff90c62bec9c6", kill_on_drop: false }` [INFO] [stderr] Compiling thiserror v2.0.18 [INFO] [stderr] Compiling disqualified v1.0.0 [INFO] [stderr] Compiling hashbrown v0.16.1 [INFO] [stderr] Compiling spin v0.10.0 [INFO] [stderr] Compiling slab v0.4.12 [INFO] [stderr] Compiling slotmap v1.1.1 [INFO] [stderr] Compiling futures-core v0.3.31 [INFO] [stderr] Compiling async-task v4.7.1 [INFO] [stderr] Compiling smallvec v1.15.1 [INFO] [stderr] Compiling bumpalo v3.19.1 [INFO] [stderr] Compiling bevy_ptr v0.18.0 [INFO] [stderr] Compiling syn v2.0.114 [INFO] [stderr] Compiling crossbeam-queue v0.3.12 [INFO] [stderr] Compiling concurrent-queue v2.5.0 [INFO] [stderr] Compiling fixedbitset v0.5.7 [INFO] [stderr] Compiling nonmax v0.5.5 [INFO] [stderr] Compiling futures-lite v2.6.1 [INFO] [stderr] Compiling downcast-rs v2.0.2 [INFO] [stderr] Compiling ringbuffer v0.16.0 [INFO] [stderr] Compiling indexmap v2.13.0 [INFO] [stderr] Compiling bevy_platform v0.18.0 [INFO] [stderr] Compiling bevy_utils v0.18.0 [INFO] [stderr] Compiling toml_edit v0.23.10+spec-1.0.0 [INFO] [stderr] Compiling bevy_macro_utils v0.18.0 [INFO] [stderr] Compiling thiserror-impl v2.0.18 [INFO] [stderr] Compiling variadics_please v1.1.0 [INFO] [stderr] Compiling derive-where v1.6.0 [INFO] [stderr] Compiling derive_more-impl v2.1.1 [INFO] [stderr] Compiling bytemuck_derive v1.10.2 [INFO] [stderr] Compiling bevy_ecs_macros v0.18.0 [INFO] [stderr] Compiling bevy_derive v0.18.0 [INFO] [stderr] Compiling bytemuck v1.25.0 [INFO] [stderr] Compiling glam v0.30.10 [INFO] [stderr] Compiling rx_core_macro_common v0.2.1 [INFO] [stderr] Compiling rx_core_macro_subscriber_derive v0.2.1 [INFO] [stderr] Compiling rx_core_macro_operator_derive v0.2.1 [INFO] [stderr] Compiling rx_core_macro_observable_derive v0.2.1 [INFO] [stderr] Compiling rx_core_macro_subscription_derive v0.2.1 [INFO] [stderr] Compiling rx_core_macro_observer_derive v0.2.1 [INFO] [stderr] Compiling rx_core_macro_subject_derive v0.2.1 [INFO] [stderr] Compiling rx_core_macro_work_derive v0.2.1 [INFO] [stderr] Compiling rx_core_macro_executor_derive v0.2.1 [INFO] [stderr] Compiling rx_core_macro_scheduler_derive v0.2.1 [INFO] [stderr] Compiling rx_core_common v0.2.1 [INFO] [stderr] Compiling rx_core_operator_composite v0.2.1 [INFO] [stderr] Compiling rx_core_subscriber_higher_order v0.2.1 [INFO] [stderr] Compiling rx_core_subject_publish v0.2.1 [INFO] [stderr] Compiling rx_core_subscription_inert v0.2.1 [INFO] [stderr] Compiling rx_core_notification_store v0.2.1 [INFO] [stderr] Compiling rx_core_notification_variadics v0.2.1 [INFO] [stderr] Compiling rx_core_observer_print v0.2.1 [INFO] [stderr] Compiling rx_core_observable_never v0.2.1 [INFO] [stderr] Compiling rx_core_observable_create v0.2.1 [INFO] [stderr] Compiling rx_core_operator_identity v0.2.1 [INFO] [stderr] Compiling rx_core_observable_timer v0.2.1 [INFO] [stderr] Compiling rx_core_scheduler_ticking v0.2.1 [INFO] [stderr] Compiling rx_core_observable_deferred v0.2.1 [INFO] [stderr] Compiling rx_core_subscriber_higher_order_all v0.2.1 [INFO] [stderr] Compiling rx_core_subscriber_higher_order_concurrent v0.2.1 [INFO] [stderr] Compiling rx_core_subscriber_higher_order_map v0.2.1 [INFO] [stderr] Compiling rx_core_operator_map v0.2.1 [INFO] [stderr] Compiling rx_core_subscriber_higher_order_switch v0.2.1 [INFO] [stderr] Compiling rx_core_subscriber_higher_order_exhaust v0.2.1 [INFO] [stderr] Compiling rx_core_operator_filter v0.2.1 [INFO] [stderr] Compiling rx_core_operator_lift_option v0.2.1 [INFO] [stderr] Compiling rx_core_observable_zip v0.2.1 [INFO] [stderr] Compiling rx_core_observable_connectable v0.2.1 [INFO] [stderr] Compiling rx_core_subject_behavior v0.2.1 [INFO] [stderr] Compiling rx_core_subject_replay v0.2.1 [INFO] [stderr] Compiling rx_core_subject_async v0.2.1 [INFO] [stderr] Compiling rx_core_observable_join v0.2.1 [INFO] [stderr] Compiling rx_core_observable_combine_latest v0.2.1 [INFO] [stderr] Compiling rx_core_observable_concat v0.2.1 [INFO] [stderr] Compiling rx_core_operator_concat_all v0.2.1 [INFO] [stderr] Compiling rx_core_operator_exhaust_map v0.2.1 [INFO] [stderr] Compiling rx_core_operator_exhaust_all v0.2.1 [INFO] [stderr] Compiling rx_core_operator_filter_map v0.2.1 [INFO] [stderr] Compiling rx_core_operator_merge_all v0.2.1 [INFO] [stderr] Compiling rx_core_operator_switch_all v0.2.1 [INFO] [stderr] Compiling rx_core_subject_provenance v0.2.1 [INFO] [stderr] Compiling rx_core_operator_switch_map v0.2.1 [INFO] [stderr] Compiling rx_core_observable_merge v0.2.1 [INFO] [stderr] Compiling rx_core_operator_concat_map v0.2.1 [INFO] [stderr] Compiling rx_core_operator_merge_map v0.2.1 [INFO] [stderr] Compiling rx_core_operator_share v0.2.1 [INFO] [stderr] Compiling rx_core_operator_retry v0.2.1 [INFO] [stderr] Compiling rx_core_observable_combine_changes v0.2.1 [INFO] [stderr] Compiling rx_core_operator_first v0.2.1 [INFO] [stderr] Compiling rx_core_operator_observe_on v0.2.1 [INFO] [stderr] Compiling rx_core_operator_reduce v0.2.1 [INFO] [stderr] Compiling rx_core_operator_pairwise v0.2.1 [INFO] [stderr] Compiling rx_core_operator_skip v0.2.1 [INFO] [stderr] Compiling rx_core_operator_finalize v0.2.1 [INFO] [stderr] Compiling rx_core_operator_debounce_time v0.2.1 [INFO] [stderr] Compiling rx_core_operator_throttle_time v0.2.1 [INFO] [stderr] Compiling rx_core_operator_end_with v0.2.1 [INFO] [stderr] Compiling rx_core_operator_buffer_count v0.2.1 [INFO] [stderr] Compiling rx_core_operator_error_boundary v0.2.1 [INFO] [stderr] Compiling rx_core_operator_materialize v0.2.1 [INFO] [stderr] Compiling rx_core_operator_fallback_when_silent v0.2.1 [INFO] [stderr] Compiling rx_core_operator_take v0.2.1 [INFO] [stderr] Compiling rx_core_operator_count v0.2.1 [INFO] [stderr] Compiling rx_core_operator_with_latest_from v0.2.1 [INFO] [stderr] Compiling rx_core_operator_tap_next v0.2.1 [INFO] [stderr] Compiling rx_core_operator_enumerate v0.2.1 [INFO] [stderr] Compiling rx_core_operator_map_into v0.2.1 [INFO] [stderr] Compiling rx_core_operator_is_empty v0.2.1 [INFO] [stderr] Compiling rx_core_operator_map_error v0.2.1 [INFO] [stderr] Compiling rx_core_operator_start_with v0.2.1 [INFO] [stderr] Compiling rx_core_operator_on_subscribe v0.2.1 [INFO] [stderr] Compiling rx_core_operator_map_never v0.2.1 [INFO] [stderr] Compiling rx_core_operator_scan v0.2.1 [INFO] [stderr] Compiling rx_core_operator_find v0.2.1 [INFO] [stderr] Compiling rx_core_operator_catch v0.2.1 [INFO] [stderr] Compiling rx_core_operator_find_index v0.2.1 [INFO] [stderr] Compiling rx_core_operator_delay v0.2.1 [INFO] [stderr] Compiling rx_core_operator_dematerialize v0.2.1 [INFO] [stderr] Compiling rx_core_operator_on_next v0.2.1 [INFO] [stderr] Compiling rx_core_operator_lift_result v0.2.1 [INFO] [stderr] Compiling rx_core_operator_into_result v0.2.1 [INFO] [stderr] Compiling rx_core_operator_tap v0.2.1 [INFO] [stderr] Compiling rx_core_operator_element_at v0.2.1 [INFO] [stderr] Compiling rx_core_observable_throw v0.2.1 [INFO] [stderr] Compiling rx_core_observable_iterator v0.2.1 [INFO] [stderr] Compiling rx_core_observable_just v0.2.1 [INFO] [stderr] Compiling rx_core_observable_empty v0.2.1 [INFO] [stderr] Compiling rx_core_observable_closed v0.2.1 [INFO] [stderr] Compiling rx_core_operator_subscribe_on v0.2.1 [INFO] [stderr] Compiling rx_core_observable_interval v0.2.1 [INFO] [stderr] Compiling rx_core_observer_noop v0.2.1 [INFO] [stderr] Compiling rx_core_observer_fn v0.2.1 [INFO] [stderr] Compiling rx_core_observable_iterator_on_tick v0.2.1 [INFO] [stderr] Compiling derive_more v2.1.1 [INFO] [stderr] Compiling bevy_tasks v0.18.0 [INFO] [stderr] Compiling bevy_ecs v0.18.0 [INFO] [stderr] Compiling bevy_math v0.18.0 [INFO] [stderr] Compiling bevy_app v0.18.0 [INFO] [stderr] Compiling bevy_time v0.18.0 [INFO] [stderr] Compiling rx_core_operator_adsr v0.2.1 [INFO] [stderr] Compiling rx_core v0.2.1 (/opt/rustwide/workdir) [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 36.79s [INFO] running `Command { std: "docker" "inspect" "b466aa9735cd43640f7d42a045af2319dbd05bb45d4d1c1f3e0ff90c62bec9c6", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "b466aa9735cd43640f7d42a045af2319dbd05bb45d4d1c1f3e0ff90c62bec9c6", kill_on_drop: false }` [INFO] [stdout] b466aa9735cd43640f7d42a045af2319dbd05bb45d4d1c1f3e0ff90c62bec9c6 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+dec9417b8611e34e787a3e4c37686b5131f9e5c5" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 633f9dcefffd2794db7d45712bc622f9762c24ccb1a53e6bc5de31a11768a876 [INFO] running `Command { std: "docker" "start" "-a" "633f9dcefffd2794db7d45712bc622f9762c24ccb1a53e6bc5de31a11768a876", kill_on_drop: false }` [INFO] [stderr] Compiling rx_core_testing v0.2.1 [INFO] [stderr] Compiling rx_core v0.2.1 (/opt/rustwide/workdir) [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 1m 08s [INFO] running `Command { std: "docker" "inspect" "633f9dcefffd2794db7d45712bc622f9762c24ccb1a53e6bc5de31a11768a876", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "633f9dcefffd2794db7d45712bc622f9762c24ccb1a53e6bc5de31a11768a876", kill_on_drop: false }` [INFO] [stdout] 633f9dcefffd2794db7d45712bc622f9762c24ccb1a53e6bc5de31a11768a876 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+dec9417b8611e34e787a3e4c37686b5131f9e5c5" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] 1aae9cd789dd980e4fa9bb587a5bac6b7946ac7c5994ef92bbb969ba032044ad [INFO] running `Command { std: "docker" "start" "-a" "1aae9cd789dd980e4fa9bb587a5bac6b7946ac7c5994ef92bbb969ba032044ad", kill_on_drop: false }` [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.63s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/rx_core-d6154b2c6fea26a6) [INFO] [stdout] [INFO] [stdout] running 0 tests [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] [stderr] Running tests/adsr_operator_tests.rs (/opt/rustwide/target/debug/deps/adsr_operator_tests-9d43c79eefd08923) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_if_downstream_closes_early ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test operator::emits_release_and_stop_after_deactivation ... ok [INFO] [stdout] test contracts::rx_contract_closed_if_downstream_closes_immediately ... ok [INFO] [stdout] test operator::emits_attack_decay_and_sustain_over_time ... ok [INFO] [stdout] test compose::should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/async_subject_test.rs (/opt/rustwide/target/debug/deps/async_subject_test-2189422e66b312aa) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test should_be_able_to_read_its_latest_value ... ok [INFO] [stdout] test should_be_closed_after_completion ... ok [INFO] [stdout] test should_be_closed_after_unsubscribe ... ok [INFO] [stdout] test should_be_closed_after_error ... ok [INFO] [stdout] test should_emit_the_last_value_after_completed_and_unsubscribe ... ok [INFO] [stdout] test should_be_able_to_use_a_custom_reducer_to_accumulate_the_result ... ok [INFO] [stdout] test should_emit_the_last_value_after_completed_for_late_subscribers ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/behavior_subject_test.rs (/opt/rustwide/target/debug/deps/behavior_subject_test-44155113787c8fad) [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test should_be_closed_after_completion ... ok [INFO] [stdout] test should_be_able_to_default_if_the_input_type_can ... ok [INFO] [stdout] test should_be_closed_after_unsubscribe ... ok [INFO] [stdout] test should_let_the_last_value_to_be_read_without_subscribing ... ok [INFO] [stdout] test should_replay_its_value_to_new_subscribers ... ok [INFO] [stdout] test should_continue_to_multicast ... ok [INFO] [stdout] test should_not_emit_the_last_value_after_errored ... ok [INFO] [stdout] test should_emit_the_last_value_after_completed_for_late_subscribers ... ok [INFO] [stdout] test should_be_closed_after_error ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/buffer_count_operator_test.rs (/opt/rustwide/target/debug/deps/buffer_count_operator_test-a69e5c0cf63c8154) [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_buffer_values_up_to_buffer_size ... ok [INFO] [stdout] test should_complete_normally_without_emitting_anything_if_there_is_no_buffer_anymore ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_error_normally_without_emitting_anything_even_if_there_was_a_buffer ... ok [INFO] [stdout] test should_unsubscribe_normally ... ok [INFO] [stdout] test should_complete_normally_without_emitting_anything_if_there_is_no_buffer_yet ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s [INFO] [stdout] [INFO] [stderr] Running tests/catch_operator_test.rs (/opt/rustwide/target/debug/deps/catch_operator_test-02b93ebf44a83903) [INFO] [stdout] [INFO] [stdout] running 6 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test compose::should_compose ... ok [INFO] [stdout] test feature::should_catch_an_upstream_error ... ok [INFO] [stdout] test teardown::should_catch_an_upstream_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/closed_observable_test.rs (/opt/rustwide/target/debug/deps/closed_observable_test-3db84cbac3fe3b78) [INFO] [stdout] [INFO] [stdout] running 2 tests [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_immediately_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/combine_changes_observable_test.rs (/opt/rustwide/target/debug/deps/combine_changes_observable_test-9e14d8720a78dc6b) [INFO] [stdout] [INFO] [stdout] running 15 tests [INFO] [stdout] test before_primed::should_not_complete_when_only_one_of_the_observables_complete_and_not_unsubscribe ... ok [INFO] [stderr] Running tests/combine_latest_observable_test.rs (/opt/rustwide/target/debug/deps/combine_latest_observable_test-b8b4467b6cb0ccc9) [INFO] [stdout] test after_primed::should_not_complete_when_one_input_observable_completes ... ok [INFO] [stdout] test before_primed::should_not_complete_when_one_input_observable_completes_with_values_already_emitted_while_the_other_is_waiting ... ok [INFO] [stdout] test before_primed::should_be_possible_to_emit_even_if_one_of_the_input_observables_had_immediately_completed ... ok [INFO] [stdout] test before_primed::should_not_unsubscribe_when_one_input_observable_unsubscribes_with_values_already_emitted_while_the_other_is_waiting ... ok [INFO] [stdout] test before_primed::should_be_possible_to_emit_even_if_one_of_the_input_observables_had_immediately_closed ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test after_primed::should_only_complete_after_both_observables_completed ... ok [INFO] [stdout] test before_primed::should_unsubscribe_when_both_of_the_observables_unsubscribe_without_emitting_values_before ... ok [INFO] [stdout] test errors::should_error_downstream_when_the_first_observable_errors ... ok [INFO] [stdout] test errors::should_error_downstream_when_the_second_observable_errors ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_only_emit_after_both_observables_emitted_even_if_its_not_in_order ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test after_primed::should_not_complete_when_only_one_observable_completed_and_the_other_just_unsubscribed ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 15 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 13 tests [INFO] [stdout] test before_primed::should_not_unsubscribe_when_one_input_observable_unsubscribes_with_values_already_emitted_while_the_other_is_waiting ... ok [INFO] [stdout] test after_primed::should_only_complete_after_both_observables_completed ... ok [INFO] [stdout] test errors::should_error_downstream_when_the_first_observable_errors ... ok [INFO] [stdout] test after_primed::should_not_complete_when_one_input_observable_completes ... ok [INFO] [stdout] test after_primed::should_not_complete_when_only_one_observable_completed_and_the_other_just_unsubscribed ... ok [INFO] [stdout] test before_primed::should_not_complete_when_one_input_observable_completes_with_values_already_emitted_while_the_other_is_waiting ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test before_primed::when_one_input_observable_completes::should_just_unsubscribe ... ok [INFO] [stdout] test errors::should_error_downstream_when_the_second_observable_errors ... ok [INFO] [stdout] test should_only_emit_after_both_observables_emitted_even_if_its_not_in_order ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test before_primed::should_unsubscribe_but_not_complete_when_one_of_the_observables_unsubscribe_without_emitting_values_before ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 13 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/composite_operator_test.rs (/opt/rustwide/target/debug/deps/composite_operator_test-e6faa4669466098a) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_create_a_new_operator_from_two_and_complete ... ok [INFO] [stdout] test should_create_a_new_operator_from_two_and_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_create_a_new_operator_from_two ... ok [INFO] [stdout] test should_create_a_new_operator_from_two_using_compose_with ... ok [INFO] [stderr] Running tests/concat_all_operator_tests.rs (/opt/rustwide/target/debug/deps/concat_all_operator_tests-55c7a4f2d3f70e69) [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.04s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_compose_and_concat_all_iterators ... ok [INFO] [stdout] test should_immediately_error_by_an_inner_error ... ok [INFO] [stdout] test should_subscribe_to_the_inner_observables_one_at_a_time ... ok [INFO] [stdout] test should_immediately_error_by_an_upstream_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_immediately_complete_if_there_are_no_active_subscriptions ... ok [INFO] [stdout] test should_concat_all_iterators ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/concat_map_operator_tests.rs (/opt/rustwide/target/debug/deps/concat_map_operator_tests-b6e1455c15af5bcb) [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_compose_and_concat_all_iterators ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_immediately_complete_if_there_are_no_active_subscriptions ... ok [INFO] [stdout] test should_immediately_error_by_an_upstream_error ... ok [INFO] [stdout] test should_concat_all_iterators ... ok [INFO] [stdout] test should_subscribe_to_the_inner_observables_one_at_a_time ... ok [INFO] [stdout] test should_immediately_error_by_an_inner_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.04s [INFO] [stdout] [INFO] [stderr] Running tests/concat_observable_test.rs (/opt/rustwide/target/debug/deps/concat_observable_test-c057af3731cc92d7) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_immediately_complete_all_inputs_immediately_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_if_downstream_closes_immediately ... ok [INFO] [stdout] test should_complete_if_all_inputs_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_if_downstream_closes_early ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s [INFO] [stdout] [INFO] [stderr] Running tests/concurrent_subscriber_test.rs (/opt/rustwide/target/debug/deps/concurrent_subscriber_test-2d32fc3225fa338c) [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test should_be_able_to_complete_from_an_upstream_completion_if_there_are_no_inner_observables ... ok [INFO] [stdout] test should_be_able_to_forward_upstream_errors ... ok [INFO] [stdout] test should_be_able_to_execute_upstream_teardown_on_unsubscribe ... ok [INFO] [stdout] test should_execute_inner_subscriptions_teardowns ... ok [INFO] [stdout] test should_move_to_the_next_observable_in_queue_if_the_previous_one_had_finished ... ok [INFO] [stdout] test should_move_to_the_next_observable_in_queue_if_the_previous_one_had_unsubscribed ... ok [INFO] [stdout] test should_immediately_execute_teardowns_for_a_closed_subscriber ... ok [INFO] [stdout] test should_move_to_the_next_observable_in_queue_if_the_the_concurrency_limit_allows_it ... ok [INFO] [stdout] test should_not_complete_if_upstream_completes_when_there_are_active_inner_observables ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/connectable_observable_reset_on_test.rs (/opt/rustwide/target/debug/deps/connectable_observable_reset_on_test-1acd7afae1552f2f) [INFO] [stdout] [INFO] [stdout] running 11 tests [INFO] [stdout] test disconnect_on_ref_count_zero::when_disabled::should_not_disconnect_when_the_subscriber_count_drops_to_zero ... ok [INFO] [stdout] test disconnect_on_ref_count_zero::when_enabled::reset_on_disconnect::when_enabled::should_reset_when_disconnected_by_ref_count_zero ... ok [INFO] [stderr] Running tests/connectable_observable_terminal_signals_test.rs (/opt/rustwide/target/debug/deps/connectable_observable_terminal_signals_test-db72ad5babb08d5f) [INFO] [stdout] test reset_on_complete::when_disabled::should_not_reset_when_the_source_completes ... ok [INFO] [stdout] test reset_on_disconnect::when_disabled::should_not_reset_when_disconnected_manually ... ok [INFO] [stdout] test disconnect_on_ref_count_zero::when_enabled::should_disconnect_when_the_subscriber_count_drops_to_zero ... ok [INFO] [stdout] test manual_reset::should_reset_when_reset_manually ... ok [INFO] [stdout] test reset_on_complete::when_enabled::should_reset_when_the_source_completes ... ok [INFO] [stdout] test reset_on_disconnect::when_enabled::should_reset_when_disconnected_manually ... ok [INFO] [stdout] test reset_on_error::when_enabled::should_reset_when_the_source_errors ... ok [INFO] [stdout] test reset_on_error::when_disabled::should_not_reset_when_the_source_errors ... ok [INFO] [stdout] test disconnect_on_ref_count_zero::when_enabled::reset_on_disconnect::when_disabled::should_not_reset_when_disconnected_by_ref_count_zero ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 11 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 6 tests [INFO] [stdout] test when_disconnected::should_not_send_complete_downstream_when_the_source_completes ... ok [INFO] [stdout] test when_connected::should_send_error_downstream_when_the_source_errors ... ok [INFO] [stdout] test when_connected::should_send_complete_downstream_when_the_source_completes ... ok [INFO] [stdout] test when_connected::should_not_unsubsribe_downstream_when_the_source_unsubscribes ... ok [INFO] [stdout] test when_disconnected::should_not_send_error_downstream_when_the_source_errors ... ok [INFO] [stdout] test when_disconnected::should_not_unsubsribe_downstream_when_the_source_unsubscribes_and_disconnected ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/connectable_observable_test.rs (/opt/rustwide/target/debug/deps/connectable_observable_test-2079a27ddd2874fd) [INFO] [stdout] [INFO] [stdout] running 11 tests [INFO] [stdout] test connectable_options::should_default_to_using_the_publish_subject ... ok [INFO] [stdout] test connector_publish_subject::should_not_relay_signals_before_connecting ... ok [INFO] [stdout] test connector_behavior_subject::should_not_relay_signals_before_connecting_besides_the_stored_value ... ok [INFO] [stdout] test connector_publish_subject::should_not_relay_signals_while_disconnected ... ok [INFO] [stdout] test connector_publish_subject::should_relay_signals_after_connecting ... ok [INFO] [stdout] test connector_replay_subject::should_not_be_able_to_prime_a_replaying_connector_without_connecting ... ok [INFO] [stdout] test connector_replay_subject::should_not_relay_signals_before_connecting_when_its_not_primed ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stderr] Running tests/count_operator_test.rs (/opt/rustwide/target/debug/deps/count_operator_test-33d146839cdae19a) [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test connector_replay_subject::should_be_able_to_replay_when_primed_even_if_disconnected ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 11 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test when_counting::should_compose ... ok [INFO] [stdout] test when_counting::should_emit_total_on_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stderr] Running tests/create_observable_test.rs (/opt/rustwide/target/debug/deps/create_observable_test-0974d7e375dd15d1) [INFO] [stdout] test when_counting::should_emit_zero_when_no_values_were_observed ... ok [INFO] [stdout] test when_counting::should_forward_errors ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 4 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_emit_a_single_value_and_stay_open_when_no_terminal_signals_were_sent ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/debounce_time_operator_test.rs (/opt/rustwide/target/debug/deps/debounce_time_operator_test-7fa803ff095d515e) [INFO] [stdout] [INFO] [stdout] running 10 tests [INFO] [stdout] test error::should_error_immediately_and_cancel_pending_debounced_values ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test complete::should_complete_after_debounced_emission_when_pending ... ok [INFO] [stdout] test unsubscribe::should_immediately_unsubscribe_when_no_pending_values_exist ... ok [INFO] [stdout] test should_emit_only_the_latest_value_after_silence ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test complete::should_immediately_complete_when_no_pending_values_exist ... ok [INFO] [stdout] test unsubscribe::should_unsubscribe_after_debounced_emission_when_pending ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 10 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/deferred_observable_test.rs (/opt/rustwide/target/debug/deps/deferred_observable_test-4cbaeefd8d3af683) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_be_able_to_complete_normally ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test observable_fn::should_be_able_to_subscribe_to_the_source ... ok [INFO] [stdout] test should_be_able_to_error_normally ... ok [INFO] [stdout] test should_be_able_to_subscribe_to_the_source ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/delay_operator_test.rs (/opt/rustwide/target/debug/deps/delay_operator_test-904f1997f4ab4981) [INFO] [stdout] [INFO] [stdout] running 16 tests [INFO] [stdout] test complete::should_immediately_complete_when_there_were_no_delayed_emissions_yet ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test complete::should_complete_after_a_delay_when_there_are_delayed_emissions ... ok [INFO] [stdout] test complete::should_immediately_complete_when_an_emission_had_passed_and_complete_was_received_later ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test error::should_cancel_work_when_errored_even_if_the_tick_would_execute_the_already_scheduled_work ... ok [INFO] [stdout] test error::should_ignore_delay_for_errors_and_error_instantly_and_cancel_existing_delayed_emissions ... ok [INFO] [stdout] test should_skip_scheduled_next_when_downstream_closes_before_tick ... ok [INFO] [stdout] test unsubscribe::should_immediately_unsubscribe_when_an_emission_had_passed_and_unsubscribe_was_received_later ... ok [INFO] [stdout] test should_not_finish_the_iterator_when_closed_early_and_downstream_is_delayed ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_delay_a_next_emission_by_the_specified_amount_of_time ... ok [INFO] [stdout] test unsubscribe::should_immediately_unsubscribe_when_there_were_no_delayed_emissions_yet ... ok [INFO] [stdout] test should_delay_multiple_next_emissions_by_the_specified_amount_of_time ... ok [INFO] [stdout] test unsubscribe::should_unsubscribe_after_a_delay_when_there_are_delayed_emissions ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 16 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/dematerialize_operator_test.rs (/opt/rustwide/target/debug/deps/dematerialize_operator_test-fa9a2c59c1fa0582) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_simply_unsubscribe_when_the_source_unsubscribes ... ok [INFO] [stdout] test should_turn_complete_emissions_into_notifications_and_not_complete ... ok [INFO] [stdout] test should_turn_error_notifications_into_actual_error_signals ... ok [INFO] [stdout] test should_turn_next_notifications_into_actual_signals ... ok [INFO] [stdout] test should_be_composable ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/dyn_fn_observer_test.rs (/opt/rustwide/target/debug/deps/dyn_fn_observer_test-c33a1ce30dc9ca47) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_call_the_complete_fn_when_completed ... ok [INFO] [stdout] test should_call_the_next_fn_when_nexted_into ... ok [INFO] [stdout] test should_call_the_error_fn_when_errored ... ok [INFO] [stdout] test should_panic_when_errored_without_an_error_fn - should panic ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/element_at_operator_test.rs (/opt/rustwide/target/debug/deps/element_at_operator_test-14a1a4e01de99ba0) [INFO] [stdout] [INFO] [stdout] running 10 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_emit_value_at_index_and_complete ... ok [INFO] [stdout] test should_error_when_out_of_range_without_default ... ok [INFO] [stdout] test should_emit_default_when_out_of_range_with_default ... ok [INFO] [stdout] test should_emit_default_when_out_of_range_with_default_on_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_ignore_values_after_complete_even_with_delay_downstream ... ok [INFO] [stdout] test should_forward_upstream_errors_wrapped ... ok [INFO] [stdout] test should_be_composable ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 10 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/empty_observable_test.rs (/opt/rustwide/target/debug/deps/empty_observable_test-5eebe16de225f57c) [INFO] [stdout] [INFO] [stdout] running 4 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test observable_fn::should_immediately_emit_complete ... ok [INFO] [stdout] test should_immediately_emit_complete ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/end_with_operator_test.rs (/opt/rustwide/target/debug/deps/end_with_operator_test-b0d76ecf1771e266) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_not_emit_the_end_with_value_when_errored ... ok [INFO] [stdout] test should_not_emit_the_end_with_value_when_unsubscribed_without_completion ... ok [INFO] [stdout] test should_emit_the_end_with_value_right_before_completion ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/enumerate_operator_test.rs (/opt/rustwide/target/debug/deps/enumerate_operator_test-44b507696d11b7c5) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_error_normally ... ok [INFO] [stdout] test should_emit_the_upstream_value_with_an_index_attached_starting_from_zero ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/erased_observables_test.rs (/opt/rustwide/target/debug/deps/erased_observables_test-50936e4a26e08615) [INFO] [stdout] [INFO] [stdout] running 2 tests [INFO] [stdout] test should_be_able_to_convert_a_tuple ... ok [INFO] [stdout] test should_be_able_to_convert_an_array_and_mut_deref ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/erased_subscribe_extension_test.rs (/opt/rustwide/target/debug/deps/erased_subscribe_extension_test-e8d3ee29bccb9b8e) [INFO] [stdout] [INFO] [stdout] running 1 test [INFO] [stdout] test erased_subscribe_boxes_destination_and_supports_teardown ... ok [INFO] [stderr] Running tests/erased_subscription_test.rs (/opt/rustwide/target/debug/deps/erased_subscription_test-9cbeeca3c1fb5e07) [INFO] [stdout] [INFO] [stdout] test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 2 tests [INFO] [stdout] test erased_subscription_executes_teardown_on_drop ... ok [INFO] [stdout] test erased_subscription_unsubscribes_and_executes_teardown ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/error_boundary_operator_test.rs (/opt/rustwide/target/debug/deps/error_boundary_operator_test-56ae473af053188d) [INFO] [stdout] [INFO] [stdout] running 5 tests [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_next_normally ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 5 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/exhaust_all_operator_test.rs (/opt/rustwide/target/debug/deps/exhaust_all_operator_test-a68fe884e93078af) [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_compose_and_exhaust_all_iterators ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_immediately_error_by_an_upstream_error ... ok [INFO] [stdout] test should_exhaust_all_iterators ... ok [INFO] [stdout] test should_immediately_complete_if_there_are_no_active_subscriptions ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_subscribe_to_the_next_observable_only_when_there_are_no_active_inner_subscriptions ... ok [INFO] [stdout] test should_immediately_error_by_an_inner_error ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/exhaust_map_operator_tests.rs (/opt/rustwide/target/debug/deps/exhaust_map_operator_tests-0dd4cb49ae1c183e) [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_immediately_complete_if_there_are_no_active_subscriptions ... ok [INFO] [stdout] test should_compose_and_exhaust_all_iterators ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_exhaust_all_iterators ... ok [INFO] [stdout] test should_immediately_error_by_an_inner_error ... ok [INFO] [stdout] test should_immediately_error_by_an_upstream_error ... ok [INFO] [stdout] test should_subscribe_to_the_next_inner_observable_when_there_are_no_active_inner_subscriptions ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/exhaust_subscriber_test.rs (/opt/rustwide/target/debug/deps/exhaust_subscriber_test-9c9513f5c3ad9fc3) [INFO] [stdout] [INFO] [stdout] running 6 tests [INFO] [stdout] test should_immediately_complete_if_there_are_no_active_subscriptions ... ok [INFO] [stdout] test should_also_run_teardowns_on_unsubscribe ... ok [INFO] [stdout] test should_immediately_error_by_an_inner_error ... ok [INFO] [stdout] test should_also_run_teardowns_immediately_when_added_to_an_already_closed_subscriber ... ok [INFO] [stdout] test should_only_allow_new_inner_observables_once_the_current_one_finished ... ok [INFO] [stdout] test should_immediately_error_by_an_upstream_error ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/fallback_when_silent_operator_test.rs (/opt/rustwide/target/debug/deps/fallback_when_silent_operator_test-ba78eef181a9c90e) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] test should_be_able_to_immediately_next_to_its_destination ... ok [INFO] [stdout] test should_close_when_unsubscribed ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/filter_map_operator_test.rs (/opt/rustwide/target/debug/deps/filter_map_operator_test-752ab3264d9c18da) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stderr] Running tests/filter_operator_test.rs (/opt/rustwide/target/debug/deps/filter_operator_test-807b0d3899c723f7) [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test should_map_and_filter_next_emissions_using_the_mapper_provided_filtering_when_none ... ok [INFO] [stdout] test should_error_normally ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_filter_based_on_index ... ok [INFO] [stdout] test should_filter_next_emissions_using_the_predicate_provided ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_error_normally ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s [INFO] [stdout] [INFO] [stderr] Running tests/finalize_operator_test.rs (/opt/rustwide/target/debug/deps/finalize_operator_test-5b1120286f2b5396) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test should_call_the_finalizer_on_unsubscribe ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_error_normally ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_call_the_finalizer_when_unsubscribed_by_another_operator ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/find_index_operator_test.rs (/opt/rustwide/target/debug/deps/find_index_operator_test-cddb1c2c7f3adc83) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test no_match_observed_error::should_error_when_completing_before_the_result_was_found_but_notifications_were_observed ... ok [INFO] [stdout] test no_next_observed_error::should_error_when_completing_before_any_value_was_even_observed ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_emit_the_found_values_index_and_complete ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_forward_upstream_errors_wrapped ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s [INFO] [stdout] [INFO] [stderr] Running tests/find_operator_test.rs (/opt/rustwide/target/debug/deps/find_operator_test-1b9520a81f930597) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test no_next_observed_error::should_error_when_completing_before_any_value_was_even_observed ... ok [INFO] [stdout] test no_match_observed_error::should_error_when_completing_before_the_result_was_found_but_notifications_were_observed ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_emit_the_found_value_and_complete ... ok [INFO] [stdout] test should_forward_upstream_errors_wrapped ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/first_operator_test.rs (/opt/rustwide/target/debug/deps/first_operator_test-b05444cced1f93b0) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stderr] Running tests/fn_observer_test.rs (/opt/rustwide/target/debug/deps/fn_observer_test-24eed8764ed4328c) [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_be_composable ... ok [INFO] [stdout] test should_emit_and_complete_on_the_first_next ... ok [INFO] [stdout] test should_error_if_no_emission_was_observed_before_completion ... ok [INFO] [stdout] test should_forward_upstream_errors ... ok [INFO] [stdout] test should_unsubscribe_normally_if_unsubscribed_before_observing_anything ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 6 tests [INFO] [stderr] Running tests/identity_operator_test.rs (/opt/rustwide/target/debug/deps/identity_operator_test-fe06d0d4872a4f3d) [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_call_the_complete_fn_when_completed ... ok [INFO] [stdout] test should_call_the_error_fn_when_errored ... ok [INFO] [stdout] test should_call_the_next_fn_when_nexted_into ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 6 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_be_a_noop_operator ... ok [INFO] [stdout] test should_just_forward_error_calls ... ok [INFO] [stdout] test should_just_forward_complete_calls ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/interval_observable_test.rs (/opt/rustwide/target/debug/deps/interval_observable_test-8d8ed9c3db909336) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test should_emit_from_all_sources_when_any_of_them_nexts_with_default_options ... ok [INFO] [stdout] test should_only_emit_at_most_max_emissions_per_tick_for_large_ticks ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_only_emit_at_most_once_if_max_emission_per_tick_is_zero ... ok [INFO] [stdout] test should_emit_immediately_when_start_on_subscribe_is_true ... ok [INFO] [stdout] test should_stop_emitting_when_downstream_is_closed ... ok [INFO] [stderr] Running tests/into_result_operator_test.rs (/opt/rustwide/target/debug/deps/into_result_operator_test-d2e9d0a61c24e4e9) [INFO] [stdout] test should_stop_emitting_when_unsubscribed ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 6 tests [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test should_turn_error_emissions_into_results_and_not_error ... ok [INFO] [stdout] test should_turn_next_emissions_into_results ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/is_empty_operator_test.rs (/opt/rustwide/target/debug/deps/is_empty_operator_test-3ffa2dc155212a31) [INFO] [stdout] [INFO] [stdout] running 6 tests [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_emit_true_if_upstream_does_not_emit_before_it_would_complete ... ok [INFO] [stdout] test should_immediately_emit_false_if_upstream_emits_something ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/iterator_observable_test.rs (/opt/rustwide/target/debug/deps/iterator_observable_test-1a9caf36f3fb642f) [INFO] [stdout] [INFO] [stdout] running 5 tests [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test iterator_observable_should_emit_its_values_then_complete ... ok [INFO] [stdout] test iterator_observable_should_stop_when_downstream_closes_during_iteration ... ok [INFO] [stdout] test should_not_finish_the_iterator_when_closed_early ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 5 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/iterator_on_tick_observable_test.rs (/opt/rustwide/target/debug/deps/iterator_on_tick_observable_test-b91c820cb6f84d04) [INFO] [stdout] [INFO] [stdout] running 6 tests [INFO] [stdout] test when_emit_at_nth_is_zero::should_immediately_emit_all_its_values_then_complete ... ok [INFO] [stdout] test when_emit_at_nth_is_zero::should_not_finish_the_iterator_when_closed_early ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test when_emit_at_nth_is_non_zero::should_stop_early_if_downstream_gets_closed_early ... ok [INFO] [stdout] test when_emit_at_nth_is_non_zero::should_emit_its_values_every_two_ticks_then_complete ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/join_observable_test.rs (/opt/rustwide/target/debug/deps/join_observable_test-873898d535de16d0) [INFO] [stdout] [INFO] [stdout] running 12 tests [INFO] [stdout] test after_primed::should_emit_the_value_pair_once_both_complete ... ok [INFO] [stdout] test after_primed::should_emit_the_value_pair_even_when_the_complete_sequentially ... ok [INFO] [stdout] test before_primed::should_only_complete_when_both_sources_complete ... ok [INFO] [stdout] test after_primed::should_emit_the_value_pair_even_when_the_complete_sequentially_in_reverse ... ok [INFO] [stdout] test before_primed::should_only_unsubscribe_when_only_the_first_source_completes ... ok [INFO] [stdout] test before_primed::should_only_unsubscribe_when_none_of_the_sources_completes ... ok [INFO] [stdout] test before_primed::should_only_unsubscribe_when_only_the_second_source_completes ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test errors::should_error_downstream_when_the_second_observable_errors ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test errors::should_error_downstream_when_the_first_observable_errors ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 12 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s [INFO] [stdout] [INFO] [stderr] Running tests/just_observable_test.rs (/opt/rustwide/target/debug/deps/just_observable_test-19640fc875d24738) [INFO] [stdout] [INFO] [stdout] running 4 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_emit_a_single_value_then_complete ... ok [INFO] [stdout] test teardown::should_execute_teardowns_on_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/lift_option_operator_test.rs (/opt/rustwide/target/debug/deps/lift_option_operator_test-6dca50b541846394) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_error_normally ... ok [INFO] [stdout] test should_turn_unpack_okay_results_into_nexts ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_not_do_anything_when_observing_a_none ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/lift_result_operator_test.rs (/opt/rustwide/target/debug/deps/lift_result_operator_test-4e56e0a030af9f05) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test should_turn_error_results_into_actual_errors ... ok [INFO] [stdout] test should_turn_unpack_okay_results_into_nexts ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/lock_with_poison_behavior_test.rs (/opt/rustwide/target/debug/deps/lock_with_poison_behavior_test-1661415b329b07f7) [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test when_not_poisoned::read_handler_is_not_called_on_clean_lock ... ok [INFO] [stderr] Running tests/map_error_operator_test.rs (/opt/rustwide/target/debug/deps/map_error_operator_test-c5a9ec230b726ba7) [INFO] [stdout] test when_not_poisoned::write_handler_is_not_called_on_clean_lock ... ok [INFO] [stdout] test when_poisoned::lock_ignore_then_clear_controls_mutex_poison_flag ... ok [INFO] [stdout] test when_poisoned::read_lock_ignore_then_clear_controls_rw_lock_poison_flag ... ok [INFO] [stdout] test when_poisoned::lock_with_poison_behavior_runs_handler_for_mutex ... ok [INFO] [stdout] test when_poisoned::read_lock_with_poison_behavior_invokes_handler ... ok [INFO] [stdout] test when_not_poisoned::mutex_handler_is_not_called_on_clean_lock ... ok [INFO] [stdout] test when_poisoned::write_lock_ignore_then_clear_controls_rw_lock_poison_flag ... ok [INFO] [stdout] test when_poisoned::write_lock_with_poison_behavior_recovers_write_access ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_map_error_next_emissions_using_the_error_mapper_provided ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/map_into_operator_test.rs (/opt/rustwide/target/debug/deps/map_into_operator_test-dd6433fba677a723) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_map_next_emissions_using_the_mapper_provided ... ok [INFO] [stdout] test should_error_normally ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/map_never_both_operator_test.rs (/opt/rustwide/target/debug/deps/map_never_both_operator_test-b0d74bb8d0d137b6) [INFO] [stdout] [INFO] [stdout] running 3 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test compose::should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/map_never_error_operator_test.rs (/opt/rustwide/target/debug/deps/map_never_error_operator_test-ea4c715ab4e0b6f6) [INFO] [stdout] [INFO] [stdout] running 4 tests [INFO] [stdout] test compose::should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_just_forward_nexts ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/map_never_next_operator_test.rs (/opt/rustwide/target/debug/deps/map_never_next_operator_test-0f58ecbe33f1c7ad) [INFO] [stdout] [INFO] [stdout] running 4 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test compose::should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stderr] Running tests/map_operator_test.rs (/opt/rustwide/target/debug/deps/map_operator_test-abc006305d11fdcc) [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] test should_map_next_emissions_using_the_mapper_provided ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/materialize_operator_test.rs (/opt/rustwide/target/debug/deps/materialize_operator_test-1613e697fc7d4ed8) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test should_simply_unsubscribe_when_the_source_unsubscribes ... ok [INFO] [stdout] test should_turn_complete_emissions_into_notifications_and_not_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_turn_error_emissions_into_notifications_and_not_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_turn_next_emissions_into_notifications ... ok [INFO] [stderr] Running tests/merge_all_operator_tests.rs (/opt/rustwide/target/debug/deps/merge_all_operator_tests-da428262a6b678b7) [INFO] [stdout] test should_be_composable ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.06s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 11 tests [INFO] [stdout] test should_subscribe_to_as_many_of_the_inner_observables_as_the_limit_allows_it ... ok [INFO] [stdout] test should_immediately_error_by_an_inner_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_execute_all_active_inner_teardowns_when_one_errors ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_merge_all_iterators ... ok [INFO] [stdout] test should_immediately_error_by_an_upstream_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_immediately_complete_if_there_are_no_active_subscriptions ... ok [INFO] [stdout] test should_subscribe_to_all_of_the_inner_observables_if_the_limit_allows_it ... ok [INFO] [stdout] test should_compose_and_merge_all_iterators ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 11 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/merge_map_operator_tests.rs (/opt/rustwide/target/debug/deps/merge_map_operator_tests-31e61ad85f01df06) [INFO] [stdout] [INFO] [stdout] running 10 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_immediately_error_by_an_upstream_error ... ok [INFO] [stdout] test should_immediately_complete_if_there_are_no_active_subscriptions ... ok [INFO] [stdout] test should_compose_and_merge_all_iterators ... ok [INFO] [stdout] test should_immediately_error_by_an_inner_error ... ok [INFO] [stdout] test should_subscribe_to_all_of_the_inner_observables_if_the_limit_allows_it ... ok [INFO] [stdout] test should_subscribe_to_as_many_of_the_inner_observables_as_the_limit_allows_it ... ok [INFO] [stderr] Running tests/merge_observable_test.rs (/opt/rustwide/target/debug/deps/merge_observable_test-e85772d80b408cbf) [INFO] [stdout] test should_merge_all_iterators ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 10 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 13 tests [INFO] [stdout] test concurrency_limit::should_complete_even_if_the_not_yet_subscribed_source_was_already_completed ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test concurrency_limit::should_only_subscribe_to_as_many_input_observables_as_concurrency_limit_allows ... ok [INFO] [stdout] test contracts::rx_contract_closed_if_downstream_closes_early ... ok [INFO] [stdout] test should_error_when_any_errors ... ok [INFO] [stdout] test should_complete_if_all_inputs_complete ... ok [INFO] [stdout] test should_emit_from_all_sources_when_any_of_them_nexts ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_complete_when_inputs_immediately_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_not_complete_until_all_completes ... ok [INFO] [stdout] test contracts::rx_contract_closed_if_downstream_closes_immediately ... ok [INFO] [stdout] test concurrency_limit::should_treat_concurrency_limit_0_as_1 ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 13 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s [INFO] [stdout] [INFO] [stderr] Running tests/never_observable_test.rs (/opt/rustwide/target/debug/deps/never_observable_test-2f0d4b2eb38891f4) [INFO] [stdout] [INFO] [stdout] running 2 tests [INFO] [stdout] test should_not_emit_anything ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/noop_observer_test.rs (/opt/rustwide/target/debug/deps/noop_observer_test-1d24ee07c98c43eb) [INFO] [stdout] [INFO] [stdout] running 6 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error - should panic ... ok [INFO] [stdout] test nothing_should_happen_when_nexted ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_panic_when_errored_in_dev_mode - should panic ... ok [INFO] [stdout] test nothing_should_happen_when_completed ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 6 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s [INFO] [stdout] [INFO] [stderr] Running tests/notification_queue_test.rs (/opt/rustwide/target/debug/deps/notification_queue_test-74a47f0d8436481f) [INFO] [stdout] [INFO] [stdout] running 10 tests [INFO] [stdout] test overflow_behavior_drop_oldest::should_drop_the_oldest_notification_when_exceeding_limit ... ok [INFO] [stdout] test should_be_able_to_return_the_next_notification ... ok [INFO] [stdout] test overflow_behavior_ignore_next::should_drop_the_newest_notification_when_exceeding_limit ... ok [INFO] [stdout] test should_have_a_waiting_state_before_any_notification_is_received ... ok [INFO] [stdout] test should_push_a_complete_notification_with_the_complete_fn ... ok [INFO] [stdout] test should_be_able_to_step_to_next_notifications ... ok [INFO] [stdout] test should_push_an_error_notification_with_the_unsubscribe_fn ... ok [INFO] [stdout] test should_stop_waiting_after_a_next_notification_is_received ... ok [INFO] [stdout] test should_take_up_the_state_of_the_front_after_popping_a_next ... ok [INFO] [stdout] test should_push_an_error_notification_with_the_error_fn ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 10 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/notification_state_test.rs (/opt/rustwide/target/debug/deps/notification_state_test-10a77df0a52757c5) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test should_be_able_to_return_the_current_value ... ok [INFO] [stdout] test should_complete ... ok [INFO] [stdout] test should_be_able_to_take_the_current_error ... ok [INFO] [stdout] test should_error ... ok [INFO] [stdout] test should_replace_the_nexted_value ... ok [INFO] [stdout] test should_unsubscribe ... ok [INFO] [stdout] test should_be_able_to_take_the_current_value ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/observe_on_operator_test.rs (/opt/rustwide/target/debug/deps/observe_on_operator_test-1783539653bb7c79) [INFO] [stdout] [INFO] [stdout] running 16 tests [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test complete::should_complete_after_a_tick_when_there_are_scheduled_emissions ... ok [INFO] [stdout] test complete::should_immediately_complete_when_there_were_no_scheduled_emissions_yet ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test error::should_ignore_observe_on_for_errors_and_error_instantly_and_cancel_scheduled_emissions ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test error::should_cancel_work_when_errored_even_if_the_tick_would_execute_the_scheduled_work ... ok [INFO] [stdout] test should_not_finish_the_iterator_when_closed_early_and_downstream_is_observed_on ... ok [INFO] [stdout] test should_schedule_a_next_emission_on_tick ... ok [INFO] [stdout] test should_skip_scheduled_next_when_downstream_closes_before_tick ... ok [INFO] [stdout] test should_schedule_multiple_next_emissions_on_tick ... ok [INFO] [stdout] test unsubscribe::should_immediately_unsubscribe_when_there_were_no_scheduled_emissions_yet ... ok [INFO] [stdout] test unsubscribe::should_unsubscribe_after_a_tick_when_there_are_scheduled_emissions ... ok [INFO] [stdout] test unsubscribe::should_unsubscribe_after_tick_when_emission_had_passed_and_unsubscribe_was_received_later ... ok [INFO] [stderr] Running tests/on_next_operator_test.rs (/opt/rustwide/target/debug/deps/on_next_operator_test-c8d45e607ee7b0c1) [INFO] [stdout] test complete::should_complete_after_tick_when_emission_had_passed_and_complete_was_received_later ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 16 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.05s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_be_able_to_interact_with_the_destination_on_next ... ok [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_be_able_to_interact_with_the_destination_on_next_and_prevent_the_original_next ... ok [INFO] [stderr] Running tests/on_subscribe_operator_test.rs (/opt/rustwide/target/debug/deps/on_subscribe_operator_test-decca8ee843e5501) [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_be_able_to_interact_with_the_destination_on_subscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/option_observable_extension_test.rs (/opt/rustwide/target/debug/deps/option_observable_extension_test-d33dfec9fcbec021) [INFO] [stdout] [INFO] [stdout] running 2 tests [INFO] [stdout] test option_observable_none_closes_and_executes_teardown_immediately ... ok [INFO] [stdout] test option_observable_some_forwards_notifications ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/option_operator_test.rs (/opt/rustwide/target/debug/deps/option_operator_test-c87ba4e78157d606) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts_none::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts_none::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts_none::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts_some::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts_some::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts_some::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_apply_inner_operator_when_some ... ok [INFO] [stderr] Running tests/pairwise_operator_test.rs (/opt/rustwide/target/debug/deps/pairwise_operator_test-a1d340564a082993) [INFO] [stdout] test should_passthrough_when_none ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_emit_values_pairwise ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test should_error_normally ... ok [INFO] [stdout] test should_unsubscribe_normally ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/print_observer_test.rs (/opt/rustwide/target/debug/deps/print_observer_test-2757fba63f0b6918) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test clone_unsubscribe_does_not_close_original ... ok [INFO] [stderr] Running tests/provenance_subject_test.rs (/opt/rustwide/target/debug/deps/provenance_subject_test-92ece3597f261fd6) [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_complete_with_just ... ok [INFO] [stdout] test should_error_with_throw ... ok [INFO] [stdout] test should_complete_with_iterator ... ok [INFO] [stdout] test default_observer_completes ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test initial_then_by_provenance::should_emit_only_values_with_matching_provenance ... ok [INFO] [stdout] test should_be_able_to_default_if_the_input_and_provenance_types_can ... ok [INFO] [stdout] test should_provide_access_to_the_current_value ... ok [INFO] [stdout] test all::should_emit_all_values_regardless_of_provenance ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test should_error_normally ... ok [INFO] [stdout] test should_replay_its_value_to_new_subscribers ... ok [INFO] [stdout] test only_by_provenance::should_emit_only_values_with_matching_provenance ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/publish_subject_deferred_test.rs (/opt/rustwide/target/debug/deps/publish_subject_deferred_test-d1a190f7d0a25f1e) [INFO] [stdout] [INFO] [stdout] running 12 tests [INFO] [stdout] test should_be_able_to_defer_an_active_subscription_to_itself_without_adding_it_to_the_subscribers_if_the_subject_itself_was_deferred_to_be_completed_before_the_subscription ... ok [INFO] [stdout] test should_be_able_to_defer_a_pre_closed_subscription_to_itself_without_adding_it_to_the_subscribers ... ok [INFO] [stdout] test should_be_able_to_defer_and_stop_at_a_completion ... ok [INFO] [stdout] test should_be_able_to_defer_and_stop_at_an_error ... ok [INFO] [stdout] test should_be_able_to_detect_a_simple_infinite_loop_and_panic - should panic ... ok [INFO] [stdout] test should_be_able_to_subscribe_and_next_to_the_new_subscription_from_teardown ... ok [INFO] [stdout] test should_be_able_to_defer_an_active_subscription_to_itself_without_adding_it_to_the_subscribers_if_the_subject_itself_was_deferred_to_be_errored_before_the_subscription ... ok [INFO] [stdout] test should_be_able_to_handle_a_lot_of_nested_deferred_events ... ok [INFO] [stdout] test should_be_able_to_defer_an_active_subscription_to_itself_without_adding_it_to_the_subscribers_if_the_subject_itself_was_deferred_to_be_unsubscribed_before_the_subscription ... ok [INFO] [stdout] test should_be_able_to_recursively_subscribe_to_itself ... ok [INFO] [stdout] test should_be_able_to_subscribe_from_teardown ... ok [INFO] [stdout] test should_be_able_to_tear_itself_down ... ok [INFO] [stderr] Running tests/publish_subject_test.rs (/opt/rustwide/target/debug/deps/publish_subject_test-fd3c80a651073ca2) [INFO] [stdout] [INFO] [stdout] test result: ok. 12 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 17 tests [INFO] [stdout] test should_be_closed_after_completion ... ok [INFO] [stdout] test additional_teardowns_should_immediately_execute_if_the_subscription_is_already_closed ... ok [INFO] [stdout] test multicast_subscription::should_run_teardowns_instantly_when_already_closed ... ok [INFO] [stdout] test should_be_able_to_chain_subjects_as_destinations ... ok [INFO] [stdout] test should_be_closed_after_error ... ok [INFO] [stdout] test should_complete_active_subscribers ... ok [INFO] [stdout] test should_forward_values_to_multiple_active_listeners_after_completion ... ok [INFO] [stdout] test should_be_closed_after_unsubscribe ... ok [INFO] [stdout] test should_immediately_complete_and_unsubscribe_new_subscribers_if_already_complete ... ok [INFO] [stdout] test should_immediately_complete_and_unsubscribe_new_subscribers_if_already_completed ... ok [INFO] [stdout] test should_error_active_subscribers_but_not_unsubscribe_them ... ok [INFO] [stdout] test should_immediately_error_and_unsubscribe_new_subscribers_if_errored_and_unsubscribed ... ok [INFO] [stdout] test should_immediately_error_new_subscribers_if_errored_before_the_subscription ... ok [INFO] [stdout] test should_immediately_unsubscribe_new_subscribers_if_already_closed ... ok [INFO] [stdout] test should_unsubscribe_existing_subscribers_if_manually_unsubscribed ... ok [INFO] [stdout] test teardowns_added_subscriptions_from_a_subject_should_belong_to_the_subscription ... ok [INFO] [stdout] test should_not_unsubscribe_existing_subscribers_if_not_manually_unsubscribed ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 17 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/reduce_operator_test.rs (/opt/rustwide/target/debug/deps/reduce_operator_test-4fdde7bb4342f53d) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_emit_the_result_once_completed ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_emit_the_seed_once_completed_without_any_nexts ... ok [INFO] [stdout] test should_unsubscribe_normally ... ok [INFO] [stdout] test should_error_normally ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.05s [INFO] [stdout] [INFO] [stderr] Running tests/replay_subject_test.rs (/opt/rustwide/target/debug/deps/replay_subject_test-ff85dc59621e59de) [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test should_be_closed_after_completion ... ok [INFO] [stdout] test should_be_closed_after_unsubscribe ... ok [INFO] [stdout] test should_replay_its_last_value_to_new_subscribers ... ok [INFO] [stdout] test should_not_replay_if_there_is_nothing_to_replay ... ok [INFO] [stdout] test should_allow_its_buffer_to_be_read_without_subscribe ... ok [INFO] [stdout] test should_replay_its_last_value_to_new_subscribers_after_completed ... ok [INFO] [stdout] test should_replay_multiple_values_to_new_subscribers_with_larger_capacity ... ok [INFO] [stdout] test should_not_replay_its_last_value_to_new_subscribers_after_errored ... ok [INFO] [stdout] test should_be_closed_after_error ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s [INFO] [stdout] [INFO] [stderr] Running tests/retry_operator_test.rs (/opt/rustwide/target/debug/deps/retry_operator_test-08e2ebca6f0ebdcb) [INFO] [stdout] [INFO] [stdout] running 16 tests [INFO] [stdout] test should_close_when_immediately_unsubscribed ... ok [INFO] [stdout] test should_be_able_to_later_complete_if_an_immediate_error_was_retried ... ok [INFO] [stdout] test should_retry_on_immediate_errors ... ok [INFO] [stdout] test should_be_able_to_later_error_if_an_immediate_error_was_retried ... ok [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_be_able_to_later_unsubscribe_if_an_immediate_error_was_retried ... ok [INFO] [stdout] test should_be_able_to_immediately_unsubscribe_if_an_immediate_error_was_retried ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_retry_on_later_errors_but_stop_if_downstream_had_already_unsubscribed ... ok [INFO] [stdout] test should_retry_on_later_errors ... ok [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stdout] test should_retry_on_mixed_immediate_and_later_errors ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_retry_on_later_replayable_errors ... ok [INFO] [stdout] test should_be_able_to_immediately_complete_if_an_immediate_error_was_retried ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 16 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/scan_operator_test.rs (/opt/rustwide/target/debug/deps/scan_operator_test-c93ba46aecb8208c) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_complete_normally ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_emit_partial_results ... ok [INFO] [stdout] test should_error_normally ... ok [INFO] [stderr] Running tests/scheduler_handle_test.rs (/opt/rustwide/target/debug/deps/scheduler_handle_test-97ae9101d05f1a84) [INFO] [stdout] test should_unsubscribe_normally ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 2 tests [INFO] [stdout] test conversion::it_should_create_a_handle ... ok [INFO] [stdout] test poison::recovers_from_poison ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.09s [INFO] [stdout] [INFO] [stderr] Running tests/share_operator_test.rs (/opt/rustwide/target/debug/deps/share_operator_test-dc9eb179a743c2f7) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test should_automatically_connect_on_subscribe_and_share_emissions_across_all_subscribers ... ok [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] test should_handle_manual_connections_and_disconnections_and_close_when_completed ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_disconnect_when_the_ref_count_is_zero ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stderr] Running tests/skip_operator_test.rs (/opt/rustwide/target/debug/deps/skip_operator_test-7f727e20d60a05a6) [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.11s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_skip_next_emissions_using_the_skipper_provided ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/start_with_operator_test.rs (/opt/rustwide/target/debug/deps/start_with_operator_test-2e9d44adbeb78fdf) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test should_be_able_to_immediately_next_to_its_destination ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/subscribe_on_operator_test.rs (/opt/rustwide/target/debug/deps/subscribe_on_operator_test-7b8936a9c1bd3a5b) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_cancel_scheduled_subscription_when_unsubscribed_early ... ok [INFO] [stdout] test should_skip_scheduled_subscription_when_destination_closed_before_tick ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_unsubscribe_from_upstream_when_destination_closes_during_subscription ... ok [INFO] [stdout] test should_schedule_subscription_on_tick ... ok [INFO] [stdout] test should_delay_subscription_until_the_delay_elapses ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/subscriber_arc_mutex_test.rs (/opt/rustwide/target/debug/deps/subscriber_arc_mutex_test-8986a9a25d62e322) [INFO] [stdout] [INFO] [stdout] running 13 tests [INFO] [stdout] test forwards_next_through_mutex ... ok [INFO] [stdout] test forwards_unsubscribe_through_mutex ... ok [INFO] [stdout] test forwards_complete_through_mutex ... ok [INFO] [stdout] test shared_destination::access_invokes_closure ... ok [INFO] [stdout] test forwards_error_through_mutex ... ok [INFO] [stdout] test shared_destination::access_mut_invokes_closure ... ok [INFO] [stdout] test shared_destination::add_teardown_executes_on_unsubscribe ... ok [INFO] [stdout] test shared_destination::add_teardown_executes_when_poisoned ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_mutex_is_poisoned_on_complete ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_mutex_is_poisoned_on_next ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_mutex_is_poisoned_on_error ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_mutex_is_poisoned_on_unsubscribe ... ok [INFO] [stdout] test forwards_subscription_calls ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 13 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/subscriber_arc_rw_lock_test.rs (/opt/rustwide/target/debug/deps/subscriber_arc_rw_lock_test-cbaa555758feae28) [INFO] [stdout] [INFO] [stdout] running 13 tests [INFO] [stdout] test forwards_complete_through_rw_lock ... ok [INFO] [stdout] test forwards_subscription_calls ... ok [INFO] [stdout] test forwards_error_through_rw_lock ... ok [INFO] [stdout] test forwards_next_through_rw_lock ... ok [INFO] [stderr] Running tests/subscriber_arc_weak_mutex_test.rs (/opt/rustwide/target/debug/deps/subscriber_arc_weak_mutex_test-b1515d2c5d6fbe79) [INFO] [stdout] test shared_destination::access_mut_invokes_closure ... ok [INFO] [stdout] test forwards_unsubscribe_through_rw_lock ... ok [INFO] [stdout] test shared_destination::add_teardown_executes_on_unsubscribe ... ok [INFO] [stdout] test shared_destination::access_invokes_closure ... ok [INFO] [stdout] test shared_destination::add_teardown_executes_when_poisoned ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_rw_lock_is_poisoned_on_complete ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_rw_lock_is_poisoned_on_next ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_rw_lock_is_poisoned_on_error ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_rw_lock_is_poisoned_on_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 13 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 20 tests [INFO] [stdout] test after_dropped::ignores_complete_after_drop ... ok [INFO] [stdout] test after_dropped::ignores_error_after_drop ... ok [INFO] [stdout] test after_dropped::ignores_next_after_drop ... ok [INFO] [stdout] test after_dropped::ignores_unsubscribe_after_drop ... ok [INFO] [stdout] test after_dropped::returns_closed_subscription_if_target_is_missing ... ok [INFO] [stdout] test after_dropped::executes_teardown_when_target_is_missing ... ok [INFO] [stdout] test before_dropped::does_not_run_teardowns_immediately ... ok [INFO] [stdout] test before_dropped::forwards_error_before_drop ... ok [INFO] [stdout] test before_dropped::forwards_complete_before_drop ... ok [INFO] [stdout] test before_dropped::forwards_next_before_drop ... ok [INFO] [stdout] test before_dropped::runs_teardowns_after_drop_and_closes ... ok [INFO] [stdout] test before_dropped::forwards_unsubscribe_before_drop ... ok [INFO] [stdout] test shared_destination::access_invokes_closure ... ok [INFO] [stdout] test shared_destination::access_mut_invokes_closure ... ok [INFO] [stdout] test shared_destination::add_teardown_executes_when_poisoned ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_mutex_is_poisoned_on_complete ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_mutex_is_poisoned_on_next ... ok [INFO] [stdout] test when_poisoned::unsubscribes_when_mutex_is_poisoned_on_error ... ok [INFO] [stdout] test shared_destination::add_teardown_executes_on_unsubscribe ... ok [INFO] [stderr] Running tests/subscriber_option_test.rs (/opt/rustwide/target/debug/deps/subscriber_option_test-871e8c5c73230d34) [INFO] [stdout] test when_poisoned::unsubscribes_when_mutex_is_poisoned_on_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 20 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test when_none::it_should_ignore_complete_and_stay_closed ... ok [INFO] [stdout] test when_some::it_should_forward_error ... ok [INFO] [stdout] test when_some::it_should_forward_next_and_complete ... ok [INFO] [stdout] test when_none::it_should_panic_on_error_but_is_muted - should panic ... ok [INFO] [stdout] test when_none::it_should_execute_teardown_immediately_for_none_subscription ... ok [INFO] [stderr] Running tests/switch_all_operator_test.rs (/opt/rustwide/target/debug/deps/switch_all_operator_test-e5ee7ceb94d3e5e0) [INFO] [stdout] test when_some::it_should_execute_subscription_teardown_on_unsubscribe ... ok [INFO] [stdout] test when_none::it_should_treat_unsubscribe_as_no_op_and_stay_closed ... ok [INFO] [stdout] test when_none::it_should_ignore_next_and_stay_closed ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.02s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 9 tests [INFO] [stdout] test should_compose_and_switch_all_iterators ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_immediately_complete_if_there_are_no_active_subscriptions ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_immediately_error_by_an_inner_error ... ok [INFO] [stdout] test should_immediately_error_by_an_upstream_error ... ok [INFO] [stdout] test should_switch_all_iterators ... ok [INFO] [stdout] test should_subscribe_to_the_next_observable_immediately_and_unsubscribe_the_previous_subscription ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 9 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Running tests/switch_map_operator_test.rs (/opt/rustwide/target/debug/deps/switch_map_operator_test-e2871b99acc90303) [INFO] [stdout] [INFO] [stdout] running 12 tests [INFO] [stdout] test should_be_able_to_subscribe_to_different_observables_if_they_are_erased ... ok [INFO] [stdout] test should_be_able_to_execute_inner_teardown_on_switch ... ok [INFO] [stdout] test should_be_able_to_work_with_an_interval_as_the_inner_subscription ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_switch_all_iterators ... ok [INFO] [stdout] test should_compose_and_switch_all_iterators ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_immediately_complete_if_there_are_no_active_subscriptions ... ok [INFO] [stdout] test should_immediately_error_by_an_upstream_error ... ok [INFO] [stdout] test should_immediately_error_by_an_inner_error ... ok [INFO] [stdout] test should_subscribe_to_the_next_observable_immediately_and_unsubscribe_the_previous_subscription ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 12 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/switch_subscriber_test.rs (/opt/rustwide/target/debug/deps/switch_subscriber_test-568c09aa6679011f) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test should_also_run_teardowns_on_unsubscribe ... ok [INFO] [stdout] test should_immediately_complete_if_there_are_no_active_subscriptions ... ok [INFO] [stdout] test should_also_run_teardowns_immediately_when_added_to_an_already_closed_subscriber ... ok [INFO] [stdout] test should_immediately_error_by_an_inner_error ... ok [INFO] [stdout] test should_immediately_error_by_an_upstream_error ... ok [INFO] [stdout] test should_run_teardowns_of_inner_subscribers_when_switching ... ok [INFO] [stdout] test should_be_able_to_unsubscribe_early_if_downstream_is_closed ... ok [INFO] [stdout] test should_switch_to_new_input_observables_immediately ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/take_operator_test.rs (/opt/rustwide/target/debug/deps/take_operator_test-75051735e647b34f) [INFO] [stdout] [INFO] [stdout] running 11 tests [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test given_two_take_operators::when_they_are_equal::should_complete_when_the_take_count_is_reached ... ok [INFO] [stdout] test given_two_take_operators::when_downstream_is_smaller::should_complete_when_the_smaller_take_count_is_reached ... ok [INFO] [stdout] test given_two_take_operators::when_upstream_is_smaller::should_complete_when_the_smaller_take_count_is_reached ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_immediately_complete_and_unsubscribe_if_take_count_is_zero ... ok [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stderr] Running tests/tap_next_operator_test.rs (/opt/rustwide/target/debug/deps/tap_next_operator_test-9cc4c3319691ed5e) [INFO] [stdout] test should_take_the_first_n_emissions_then_complete ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 11 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 5 tests [INFO] [stdout] test compose::should_compose ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test tap_next::forwards_next_notifications_to_the_tap_fn_too ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 5 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/tap_operator_test.rs (/opt/rustwide/target/debug/deps/tap_operator_test-9c68273dcfa73fe5) [INFO] [stdout] [INFO] [stdout] running 7 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_close_when_completed ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stderr] Running tests/throttle_time_operator_test.rs (/opt/rustwide/target/debug/deps/throttle_time_operator_test-4796bc2263014d29) [INFO] [stdout] test should_forward_all_notifications_to_the_tap_destination_too ... ok [INFO] [stdout] test should_close_when_errored ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 20 tests [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test when_leading_and_trailing_true::should_allow_new_window_shortly_after_trailing_with_switch_map ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test when_trailing_true::should_ignore_next_after_unsubscribe_until_trailing_emitted ... ok [INFO] [stdout] test when_trailing_true::should_error_immediately_and_cancel_pending_throttled_values ... ok [INFO] [stdout] test when_trailing_true::should_emit_trailing_value_when_enabled ... ok [INFO] [stdout] test when_leading_and_trailing_true::should_immediately_complete_when_no_pending_values_exist ... ok [INFO] [stdout] test when_leading_and_trailing_true::should_immediately_unsubscribe_when_no_pending_values_exist ... ok [INFO] [stdout] test when_downstream_closes_early::should_stop_processing_after_downstream_closes_during_trailing_work ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test when_leading_and_trailing_true::should_immediately_complete_when_throttling_without_trailing_value ... ok [INFO] [stdout] test when_leading_false::should_delay_first_emission_when_leading_disabled ... ok [INFO] [stdout] test when_leading_and_trailing_true::should_restart_throttling_before_duration_after_trailing ... ok [INFO] [stdout] test when_leading_and_trailing_true::should_compose ... ok [INFO] [stdout] test when_trailing_true::should_complete_after_trailing_emission_when_pending ... ok [INFO] [stdout] test when_trailing_false::should_not_emit_trailing_value_when_disabled ... ok [INFO] [stdout] test when_leading_and_trailing_true::should_throttle_interval_source ... ok [INFO] [stdout] test when_trailing_false::should_ignore_values_during_throttle_when_trailing_disabled ... ok [INFO] [stdout] test when_leading_true::should_emit_immediately_then_suppress_until_duration ... ok [INFO] [stdout] test when_trailing_true::should_unsubscribe_after_trailing_emission_when_pending ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 20 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.03s [INFO] [stdout] [INFO] [stderr] Running tests/throw_observable_test.rs (/opt/rustwide/target/debug/deps/throw_observable_test-2b4c26e0bb93161d) [INFO] [stdout] [INFO] [stdout] running 3 tests [INFO] [stdout] test should_cause_an_error_on_subscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 3 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/ticking_executor_test.rs (/opt/rustwide/target/debug/deps/ticking_executor_test-473ea9e6b9044591) [INFO] [stdout] [INFO] [stdout] running 10 tests [INFO] [stdout] test invoked_work::should_be_able_to_cancel_invoked_work ... ok [INFO] [stdout] test continuous_work::should_be_able_to_execute_continous_work_on_every_tick ... ok [INFO] [stdout] test immediate_work::should_execute_nested_immediate_work_in_a_single_tick ... ok [INFO] [stdout] test delayed_work::should_execute_nested_delayed_work_in_individual_as_timer_always_start_from_now ... ok [INFO] [stdout] test immediate_work::should_not_execute_immediate_work_when_cancelled_before_tick ... ok [INFO] [stdout] test invoked_work::should_be_able_to_execute_invoked_work ... ok [INFO] [stdout] test repeated_work::should_be_able_to_start_repeated_work_immediately ... ok [INFO] [stderr] Running tests/timer_observable_test.rs (/opt/rustwide/target/debug/deps/timer_observable_test-e1e02509b5000465) [INFO] [stdout] test ticking::should_be_able_to_tick_to_arbitrary_points_after_now ... ok [INFO] [stdout] test repeated_work::should_be_able_to_schedule_repeated_work_and_execute_it_when_it_rolls_over ... ok [INFO] [stdout] test immediate_work::should_panic_when_a_work_recursively_schedules_too_much_work - should panic ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 10 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 5 tests [INFO] [stdout] test should_execute_teardowns_when_unsubscribed ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_not_send_a_unit_value_after_the_specified_amount_of_time_when_unsubscribed ... ok [INFO] [stdout] test should_send_a_unit_value_after_the_specified_amount_of_time ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 5 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/with_latest_from_operator_test.rs (/opt/rustwide/target/debug/deps/with_latest_from_operator_test-ba950c19f823ad60) [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test should_complete_when_inner_observable_completes_but_not_primed ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_compose ... ok [INFO] [stdout] test should_emit_values_with_latest_from ... ok [INFO] [stdout] test should_error_when_inner_observable_errors ... ok [INFO] [stdout] test should_not_complete_when_inner_observable_completes_but_primed ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 8 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] [stderr] Running tests/zip_observable_test.rs (/opt/rustwide/target/debug/deps/zip_observable_test-81849a010e1bc0f0) [INFO] [stdout] [INFO] [stdout] running 13 tests [INFO] [stdout] test before_primed::should_unsubscribe_but_not_complete_when_one_of_the_observables_unsubscribe ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_unsubscribe ... ok [INFO] [stdout] test after_primed::should_unsubscribe_but_not_complete_when_one_of_the_observables_unsubscribe ... ok [INFO] [stdout] test after_primed::it_should_complete_even_if_just_one_of_the_observables_complete ... ok [INFO] [stdout] test errors::should_error_downstream_when_the_first_observable_errors_after_seeing_a_value ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_complete ... ok [INFO] [stdout] test after_primed::should_properly_complete_after_draining_emitting_two_equal_sized_queues_where_the_second_queue_only_starts_after_the_first_finishes ... ok [INFO] [stdout] test errors::should_error_downstream_when_the_first_observable_errors ... ok [INFO] [stdout] test errors::should_error_downstream_when_the_second_observable_errors ... ok [INFO] [stdout] test overflow::should_properly_complete_after_draining_emitting_two_equal_sized_queues_where_the_second_queue_only_starts_after_the_first_finishes ... ok [INFO] [stdout] test before_primed::it_should_complete_even_when_only_one_of_the_observables_complete ... ok [INFO] [stdout] test contracts::rx_contract_closed_after_error ... ok [INFO] [stdout] test should_only_emit_after_both_observables_emitted_even_if_its_not_in_order ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 13 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] [stderr] Doc-tests rx_core [INFO] [stdout] [INFO] [stdout] running 0 tests [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] running `Command { std: "docker" "inspect" "1aae9cd789dd980e4fa9bb587a5bac6b7946ac7c5994ef92bbb969ba032044ad", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "1aae9cd789dd980e4fa9bb587a5bac6b7946ac7c5994ef92bbb969ba032044ad", kill_on_drop: false }` [INFO] [stdout] 1aae9cd789dd980e4fa9bb587a5bac6b7946ac7c5994ef92bbb969ba032044ad