Struct MemoryTasks 

pub struct MemoryTasks { /* private fields */ }

A TaskStore kept in memory, for runtime tests: every requester sees every task, ids are tasks/test/t-<n>, and no rule is checked.

Implementations

impl MemoryTasks

pub fn new(clock: Arc<dyn Clock>) -> Self

An empty store reading time from clock.

pub fn all(&self) -> Vec<Task>

Every task, in display order.

pub fn insert(&self, task: Task)

Adds a fully built task as it is (for tests that need a past time or an origin).

Trait Implementations

impl Debug for MemoryTasks

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl TaskStore for MemoryTasks

fn add<'life0, 'life1, 'async_trait>( &'life0 self, who: &'life1 Requester, new: NewTask, ) -> Pin<Box<dyn Future<Output = Result<Task, TaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Creates a task.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, _who: &'life1 Requester, ) -> Pin<Box<dyn Future<Output = Result<Vec<Task>, TaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Tasks visible to who (theirs and their room’s), every status, in display order: active first, then by next firing or due time, then by creation.

fn update<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _who: &'life1 Requester, id: &'life2 str, change: TaskChange, ) -> Pin<Box<dyn Future<Output = Result<Task, TaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Changes a visible task.

fn delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _who: &'life1 Requester, id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Task, TaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Deletes a visible task.

fn scheduled<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Task>, TaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Every open or paused task with a next firing, of every owner (the scheduler).

fn after_fire<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, change: TaskChange, ) -> Pin<Box<dyn Future<Output = Result<Task, TaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Changes any task by id after it fired (the scheduler; no visibility check).