arty 0.5.0

Single-threaded, thread-aware application runtime.
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

//! Scoped execution preserves owned and borrowed captures.

#![cfg(feature = "rt")]

testing_aids::init_tracing!();

use arty::runtime::Runtime;

#[test]
fn capture_by_value() {
    #[expect(clippy::useless_vec, reason = "using a vec to test with a type using pointers on the inside")]
    let vec = vec![10, 11];
    let result = Runtime::new()
        .expect("Failed to create runtime")
        .scheduler()
        .block_on(async move |_ctx| vec.len() + 10)
        .unwrap();
    assert_eq!(result, 12);
}

#[test]
fn move_and_spawn() {
    #[expect(clippy::useless_vec, reason = "using a vec to test with a type using pointers on the inside")]
    let vec = vec![10, 11];
    let result = Runtime::new()
        .expect("Failed to create runtime")
        .scheduler()
        .block_on(async move |ctx| {
            let child = ctx.scheduler().spawn(async move |_ctx| vec.len() + 10);
            child.await.unwrap()
        })
        .unwrap();
    assert_eq!(result, 12);
}

#[test]
fn capture_reference() {
    let vec = vec![10, 11];
    let result = Runtime::new()
        .expect("Failed to create runtime")
        .scheduler()
        .block_on(async |_ctx| {
            let vec_ref = &vec;
            vec_ref.len() + 10
        })
        .unwrap();
    assert_eq!(vec.len() + 10, result);
}

#[test]
fn capture_mut_reference() {
    let mut vec = vec![10, 11];
    let result = Runtime::new()
        .expect("Failed to create runtime")
        .scheduler()
        .block_on(async |_ctx| {
            let vec_ref = &mut vec;
            vec_ref.push(15);
            vec_ref.len() + 10
        })
        .unwrap();
    assert_eq!(vec.len() + 10, result);
    assert_eq!(vec.len(), 3);
}