near-async 0.35.0

This crate contains the async helpers specific for nearcore
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

use crate::futures::DelayedActionRunner;

type FakeDelayedActionTask<T> =
    Box<dyn FnOnce(&mut T, &mut dyn DelayedActionRunner<T>) + Send + 'static>;

/// Queues all actions until `run_queued_actions` is called.
pub struct FakeDelayedActionRunner<T> {
    tasks: Vec<FakeDelayedActionTask<T>>,
}

// For some reason deriving Default sets a constrain for T to implement Default so instead we
// implement Default trait by hand.
impl<T> Default for FakeDelayedActionRunner<T> {
    fn default() -> Self {
        FakeDelayedActionRunner { tasks: Vec::new() }
    }
}

impl<T> DelayedActionRunner<T> for FakeDelayedActionRunner<T> {
    fn run_later_boxed(
        &mut self,
        _name: &'static str,
        _dur: crate::time::Duration,
        f: FakeDelayedActionTask<T>,
    ) {
        self.tasks.push(f);
    }
}

impl<T> FakeDelayedActionRunner<T> {
    pub fn run_queued_actions(&mut self, actor: &mut T) {
        let tasks = std::mem::take(&mut self.tasks);
        for task in tasks {
            task(actor, self);
        }
    }
}