fibril 0.0.8

A library for implementing distributed systems with commmunicating fibers.
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

use {
    crate::Sdk,
    corosensei::{stack::DefaultStack, CoroutineResult, ScopedCoroutine},
    fibril_core::{Command, Event, Step},
};

pub struct Fiber<'a, M>(ScopedCoroutine<'a, Event<M>, Command<M>, (), DefaultStack>);

impl<'a, M> Fiber<'a, M> {
    pub fn new(behavior: impl FnOnce(Sdk<'_, M>) + 'a) -> Self {
        Self(ScopedCoroutine::new(move |yielder, spawn_ok| {
            let id = match spawn_ok {
                Event::SpawnOk(id) => id,
                _ => unreachable!(),
            };
            behavior(Sdk(yielder, id))
        }))
    }
}
impl<M> Step<M> for Fiber<'_, M> {
    fn step(&mut self, event: Event<M>) -> Command<M> {
        match self.0.resume(event) {
            CoroutineResult::Yield(command) => command,
            CoroutineResult::Return(()) => Command::Exit,
        }
    }
}