[INFO] fetching crate fmodel-rust 0.8.1...
[INFO] checking fmodel-rust-0.8.1 against master#8c32e313cccf7df531e2d49ffb8227bb92304aee for pr-145608-1
[INFO] extracting crate fmodel-rust 0.8.1 into /workspace/builds/worker-2-tc1/source
[INFO] started tweaking crates.io crate fmodel-rust 0.8.1
[INFO] removed 0 missing tests
[INFO] finished tweaking crates.io crate fmodel-rust 0.8.1
[INFO] tweaked toml for crates.io crate fmodel-rust 0.8.1 written to /workspace/builds/worker-2-tc1/source/Cargo.toml
[INFO] validating manifest of crates.io crate fmodel-rust 0.8.1 on toolchain 8c32e313cccf7df531e2d49ffb8227bb92304aee
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+8c32e313cccf7df531e2d49ffb8227bb92304aee" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate crates.io crate fmodel-rust 0.8.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" "+8c32e313cccf7df531e2d49ffb8227bb92304aee" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded unicode-ident v1.0.11
[INFO] [stderr]   Downloaded rustc-demangle v0.1.23
[INFO] [stderr]   Downloaded unicode-xid v0.2.4
[INFO] [stderr]   Downloaded proc-macro2 v1.0.89
[INFO] [stderr]   Downloaded miniz_oxide v0.7.1
[INFO] [stderr]   Downloaded cc v1.0.83
[INFO] [stderr]   Downloaded derive_more v2.0.1
[INFO] [stderr]   Downloaded derive_more-impl v2.0.1
[INFO] [stderr]   Downloaded memchr v2.6.3
[INFO] [stderr]   Downloaded backtrace v0.3.69
[INFO] [stderr]   Downloaded io-uring v0.7.8
[INFO] [stderr]   Downloaded syn v2.0.82
[INFO] [stderr]   Downloaded gimli v0.28.0
[INFO] [stderr]   Downloaded object v0.32.1
[INFO] [stderr]   Downloaded tokio v1.46.1
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+8c32e313cccf7df531e2d49ffb8227bb92304aee" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 55c556951486f38ea2159197449e78de570979c6ebb75847f90db71b040dfdc7
[INFO] running `Command { std: "docker" "start" "-a" "55c556951486f38ea2159197449e78de570979c6ebb75847f90db71b040dfdc7", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "55c556951486f38ea2159197449e78de570979c6ebb75847f90db71b040dfdc7", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "55c556951486f38ea2159197449e78de570979c6ebb75847f90db71b040dfdc7", kill_on_drop: false }`
[INFO] [stdout] 55c556951486f38ea2159197449e78de570979c6ebb75847f90db71b040dfdc7
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+8c32e313cccf7df531e2d49ffb8227bb92304aee" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] f053dc3f45b658f52279629c9c8bfb319e1183ab23312de2e946790d84417c98
[INFO] running `Command { std: "docker" "start" "-a" "f053dc3f45b658f52279629c9c8bfb319e1183ab23312de2e946790d84417c98", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.89
[INFO] [stderr]    Compiling unicode-ident v1.0.11
[INFO] [stderr]    Compiling serde v1.0.219
[INFO] [stderr]    Compiling unicode-xid v0.2.4
[INFO] [stderr]     Checking pin-project-lite v0.2.13
[INFO] [stderr]    Compiling quote v1.0.35
[INFO] [stderr]    Compiling syn v2.0.82
[INFO] [stderr]    Compiling serde_derive v1.0.219
[INFO] [stderr]    Compiling tokio-macros v2.5.0
[INFO] [stderr]    Compiling derive_more-impl v2.0.1
[INFO] [stderr]     Checking tokio v1.46.1
[INFO] [stderr]     Checking derive_more v2.0.1
[INFO] [stderr]     Checking fmodel-rust v0.8.1 (/opt/rustwide/workdir)
[INFO] [stdout] warning: struct `OrderState` is never constructed
[INFO] [stdout]  --> tests/api/mod.rs:9:12
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub struct OrderState {
[INFO] [stdout]   |            ^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderView2State` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:27:12
[INFO] [stdout]    |
[INFO] [stdout] 27 | pub struct OrderView2State {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:117:12
[INFO] [stdout]     |
[INFO] [stdout] 117 | pub struct ShipmentState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderViewState` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:18:12
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub struct OrderViewState {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderView2State` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:27:12
[INFO] [stdout]    |
[INFO] [stdout] 27 | pub struct OrderView2State {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentViewState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:126:12
[INFO] [stdout]     |
[INFO] [stdout] 126 | pub struct ShipmentViewState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderState` is never constructed
[INFO] [stdout]  --> tests/api/mod.rs:9:12
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub struct OrderState {
[INFO] [stdout]   |            ^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderViewState` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:18:12
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub struct OrderViewState {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderView2State` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:27:12
[INFO] [stdout]    |
[INFO] [stdout] 27 | pub struct OrderView2State {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:117:12
[INFO] [stdout]     |
[INFO] [stdout] 117 | pub struct ShipmentState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentViewState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:126:12
[INFO] [stdout]     |
[INFO] [stdout] 126 | pub struct ShipmentViewState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderState` is never constructed
[INFO] [stdout]  --> tests/api/mod.rs:9:12
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub struct OrderState {
[INFO] [stdout]   |            ^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderView2State` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:27:12
[INFO] [stdout]    |
[INFO] [stdout] 27 | pub struct OrderView2State {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:117:12
[INFO] [stdout]     |
[INFO] [stdout] 117 | pub struct ShipmentState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentViewState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:126:12
[INFO] [stdout]     |
[INFO] [stdout] 126 | pub struct ShipmentViewState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderState` is never constructed
[INFO] [stdout]  --> tests/api/mod.rs:9:12
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub struct OrderState {
[INFO] [stdout]   |            ^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderView2State` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:27:12
[INFO] [stdout]    |
[INFO] [stdout] 27 | pub struct OrderView2State {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:117:12
[INFO] [stdout]     |
[INFO] [stdout] 117 | pub struct ShipmentState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderState` is never constructed
[INFO] [stdout]  --> tests/api/mod.rs:9:12
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub struct OrderState {
[INFO] [stdout]   |            ^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderViewState` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:18:12
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub struct OrderViewState {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderView2State` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:27:12
[INFO] [stdout]    |
[INFO] [stdout] 27 | pub struct OrderView2State {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:117:12
[INFO] [stdout]     |
[INFO] [stdout] 117 | pub struct ShipmentState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentViewState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:126:12
[INFO] [stdout]     |
[INFO] [stdout] 126 | pub struct ShipmentViewState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderState` is never constructed
[INFO] [stdout]  --> tests/api/mod.rs:9:12
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub struct OrderState {
[INFO] [stdout]   |            ^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderViewState` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:18:12
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub struct OrderViewState {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderView2State` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:27:12
[INFO] [stdout]    |
[INFO] [stdout] 27 | pub struct OrderView2State {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:117:12
[INFO] [stdout]     |
[INFO] [stdout] 117 | pub struct ShipmentState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentViewState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:126:12
[INFO] [stdout]     |
[INFO] [stdout] 126 | pub struct ShipmentViewState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderViewState` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:18:12
[INFO] [stdout]    |
[INFO] [stdout] 18 | pub struct OrderViewState {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `OrderView2State` is never constructed
[INFO] [stdout]   --> tests/api/mod.rs:27:12
[INFO] [stdout]    |
[INFO] [stdout] 27 | pub struct OrderView2State {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:117:12
[INFO] [stdout]     |
[INFO] [stdout] 117 | pub struct ShipmentState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ShipmentViewState` is never constructed
[INFO] [stdout]    --> tests/api/mod.rs:126:12
[INFO] [stdout]     |
[INFO] [stdout] 126 | pub struct ShipmentViewState {
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0275]: overflow evaluating the requirement `EventSourcedOrchestratingAggregate<'_, application::Command, (OrderState, ShipmentState), Event, InMemoryEventRepository, i32, ...>: Sync`
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider increasing the recursion limit by adding a `#![recursion_limit = "256"]` attribute to your crate (`aggregate_combined_test`)
[INFO] [stdout]     = note: required for `&EventSourcedOrchestratingAggregate<'_, ..., ..., ..., ..., i32, ...>` to implement `Send`
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:324:5
[INFO] [stdout]     |
[INFO] [stdout] 324 | /     {
[INFO] [stdout] 325 | |         let events: Vec<(E, Version)> = self.fetch_events(command).await?;
[INFO] [stdout] 326 | |         let mut current_events: Vec<E> = vec![];
[INFO] [stdout] 327 | |         for (event, _) in events {
[INFO] [stdout] ...   |
[INFO] [stdout] 334 | |         Ok(saved_events)
[INFO] [stdout] 335 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` block
[INFO] [stdout]    --> tests/aggregate_combined_test.rs:396:36
[INFO] [stdout]     |
[INFO] [stdout] 396 |     let handle1 = thread::spawn(|| async move {
[INFO] [stdout]     |                                    ^^^^^^^^^^
[INFO] [stdout]     = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/aggregate_combined_test-723405842b31a16a.long-type-884888645331202982.txt'
[INFO] [stdout]     = note: consider using `--verbose` to print the full type name to the console
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0275]: overflow evaluating the requirement `EventSourcedOrchestratingAggregate<'_, application::Command, (OrderState, ShipmentState), Event, InMemoryEventRepository, i32, ...>: Sync`
[INFO] [stdout]    --> tests/aggregate_combined_test.rs:396:19
[INFO] [stdout]     |
[INFO] [stdout] 396 |       let handle1 = thread::spawn(|| async move {
[INFO] [stdout]     |  ___________________^
[INFO] [stdout] 397 | |         let command = Command::OrderCreate(CreateOrderCommand {
[INFO] [stdout] 398 | |             order_id: 1,
[INFO] [stdout] 399 | |             customer_name: "John Doe".to_string(),
[INFO] [stdout] ...   |
[INFO] [stdout] 459 | |         );
[INFO] [stdout] 460 | |     });
[INFO] [stdout]     | |______^
[INFO] [stdout]     |
[INFO] [stdout]     = help: consider increasing the recursion limit by adding a `#![recursion_limit = "256"]` attribute to your crate (`aggregate_combined_test`)
[INFO] [stdout]     = note: required for `&EventSourcedOrchestratingAggregate<'_, ..., ..., ..., ..., i32, ...>` to implement `Send`
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout]     = note: required for `Unique<impl Future<Output = Result<Vec<Event>, AggregateError>>>` to implement `Send`
[INFO] [stdout] note: required because it appears within the type `Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/alloc/src/boxed.rs:231:12
[INFO] [stdout] note: required because it appears within the type `Pin<Box<impl Future<Output = Result<Vec<Event>, AggregateError>>>>`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/core/src/pin.rs:1094:12
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:348:5
[INFO] [stdout]     |
[INFO] [stdout] 348 | /     {
[INFO] [stdout] 349 | |         let current_state: S = current_events
[INFO] [stdout] 350 | |             .iter()
[INFO] [stdout] 351 | |             .fold((self.decider.initial_state)(), |state, event| {
[INFO] [stdout] ...   |
[INFO] [stdout] 388 | |         Ok(all_events)
[INFO] [stdout] 389 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` fn body
[INFO] [stdout]    --> /opt/rustwide/workdir/src/aggregate.rs:324:5
[INFO] [stdout]     |
[INFO] [stdout] 324 | /     {
[INFO] [stdout] 325 | |         let events: Vec<(E, Version)> = self.fetch_events(command).await?;
[INFO] [stdout] 326 | |         let mut current_events: Vec<E> = vec![];
[INFO] [stdout] 327 | |         for (event, _) in events {
[INFO] [stdout] ...   |
[INFO] [stdout] 334 | |         Ok(saved_events)
[INFO] [stdout] 335 | |     }
[INFO] [stdout]     | |_____^
[INFO] [stdout] note: required because it's used within this `async` block
[INFO] [stdout]    --> tests/aggregate_combined_test.rs:396:36
[INFO] [stdout]     |
[INFO] [stdout] 396 |     let handle1 = thread::spawn(|| async move {
[INFO] [stdout]     |                                    ^^^^^^^^^^
[INFO] [stdout] note: required by a bound in `std::thread::spawn`
[INFO] [stdout]    --> /rustc/8c32e313cccf7df531e2d49ffb8227bb92304aee/library/std/src/thread/mod.rs:723:1
[INFO] [stdout]     = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/aggregate_combined_test-723405842b31a16a.long-type-9750230663026813380.txt'
[INFO] [stdout]     = note: consider using `--verbose` to print the full type name to the console
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `fmodel-rust` (test "aggregate_combined_test") due to 2 previous errors
[INFO] [stdout] For more information about this error, try `rustc --explain E0275`.
[INFO] [stdout] 
[INFO] running `Command { std: "docker" "inspect" "f053dc3f45b658f52279629c9c8bfb319e1183ab23312de2e946790d84417c98", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "f053dc3f45b658f52279629c9c8bfb319e1183ab23312de2e946790d84417c98", kill_on_drop: false }`
[INFO] [stdout] f053dc3f45b658f52279629c9c8bfb319e1183ab23312de2e946790d84417c98