aurelia 0.2.0

Embeddable service mesh for Rust distributed applications.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

// This file is part of the Aurelia workspace.
// SPDX-FileCopyrightText: 2026 Zivatar Limited
// SPDX-License-Identifier: Apache-2.0

use super::*;

struct DropSignal(Option<oneshot::Sender<()>>);

impl Drop for DropSignal {
    fn drop(&mut self) {
        if let Some(tx) = self.0.take() {
            let _ = tx.send(());
        }
    }
}

#[tokio::test]
async fn dropping_task_set_aborts_task_holding_spawner_clone() {
    let runtime_handle = tokio::runtime::Handle::current();
    let task_set = PeerTaskSet::new(&runtime_handle);
    let spawner = task_set.spawner();
    let (started_tx, started_rx) = oneshot::channel();
    let (dropped_tx, dropped_rx) = oneshot::channel();
    let held_spawner = spawner.clone();

    spawner.spawn(async move {
        let _held_spawner = held_spawner;
        let _drop_signal = DropSignal(Some(dropped_tx));
        let _ = started_tx.send(());
        std::future::pending::<()>().await;
    });

    timeout(Duration::from_millis(250), started_rx)
        .await
        .expect("task should start")
        .expect("start signal");
    drop(task_set);

    timeout(Duration::from_millis(250), dropped_rx)
        .await
        .expect("task should be aborted")
        .expect("drop signal");
}