uniflow 0.2.1

A unidirectional data flow state management library
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

use futures::executor::{LocalPool, LocalSpawner};
use futures::task::LocalSpawnExt;
use std::cell::RefCell;

thread_local! {
    static LOCAL_POOL: RefCell<LocalPool> = RefCell::new(LocalPool::new());
    static LOCAL_SPAWNER: LocalSpawner = LOCAL_POOL.with(|pool| pool.borrow().spawner());
}

pub struct SynchronousExecutor;

impl any_spawner::CustomExecutor for SynchronousExecutor {
    fn spawn(&self, fut: any_spawner::PinnedFuture<()>) {
        self.spawn_local(fut);
    }

    fn spawn_local(&self, fut: any_spawner::PinnedLocalFuture<()>) {
        LOCAL_SPAWNER.with(|spawner| {
            spawner.spawn_local(fut).unwrap();
        });
    }

    fn poll_local(&self) {
        LOCAL_POOL.with(|pool| {
            pool.borrow_mut().run_until_stalled();
        });
    }
}

pub fn tick() {
    any_spawner::Executor::poll_local();
}

pub fn init_test_executer() -> Result<(), any_spawner::ExecutorError> {
    any_spawner::Executor::init_custom_executor(SynchronousExecutor)
}