Type Alias jormungandr::blockchain::process::PullHeadersScheduler

type PullHeadersScheduler = FireForgetScheduler<HeaderHash, NodeId, Checkpoints>;

Aliased Type

struct PullHeadersScheduler {
    sender: Sender<Command<Hash, NodeId, Checkpoints>>,
}

Fields

sender: Sender<Command<Hash, NodeId, Checkpoints>>

Implementations

impl<TID, WID, Data> FireForgetScheduler<TID, WID, Data>

pub fn schedule(&mut self, tid: TID, wid: WID, data: Data) -> Result<(), Error>

Schedules a task to be launched. If task with same TID and WID is already queued, it has no effect.

pub fn declare_completed(&mut self, task: TID) -> Result<(), Error>

Declares all tasks with given TID completed. Queued instances will be canceled and running ones will be considered finished.

fn try_send(&mut self, command: Command<TID, WID, Data>) -> Result<(), Error>

Trait Implementations

impl<TID, WID, Data> Clone for FireForgetScheduler<TID, WID, Data>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.