corophage 0.4.1

Algebraic effects for stable Rust
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

use corophage::coroutine::CoSend;
use corophage::prelude::*;
use corophage::sync;

use crate::common::*;

fn assert_send<T: Send>(_: &T) {}

#[test]
fn co_send_is_send() {
    fn co() -> CoSend<'static, Effects![FileRead], String> {
        CoSend::new(|y| async move { y.yield_(FileRead("test".to_string())).await })
    }

    let co = co();
    assert_send(&co);
}

#[tokio::test]
#[cfg_attr(miri, ignore)]
async fn co_send_can_be_spawned() {
    fn co() -> CoSend<'static, Effects![FileRead], String> {
        CoSend::new(|y| async move { y.yield_(FileRead("test".to_string())).await })
    }

    let handle = tokio::spawn(async move {
        sync::run(
            co(),
            &mut hlist![|FileRead(file)| {
                println!("Reading file: {file}");
                Control::resume("file content".to_string())
            }],
        )
    });

    let result = handle.await.unwrap();
    assert_eq!(result, Ok("file content".to_string()));
}