Struct BasicQueue

pub struct BasicQueue<B: BlockT> { /* private fields */ }

Interface to a basic block import queue that is importing blocks sequentially in a separate task, with plugable verification.

Implementations

impl<B: BlockT> BasicQueue<B>

pub fn new<V>( verifier: V, block_import: BoxBlockImport<B>, justification_import: Option<BoxJustificationImport<B>>, spawner: &impl SpawnEssentialNamed, prometheus_registry: Option<&Registry>, ) -> Self

where V: Verifier<B> + 'static,

Instantiate a new basic queue, with given verifier.

This creates a background task, and calls on_start on the justification importer.

Trait Implementations

impl<B: BlockT> Drop for BasicQueue<B>

fn drop(&mut self)

Executes the destructor for this type.

impl<B: BlockT> ImportQueue<B> for BasicQueue<B>

fn service(&self) -> Box<dyn ImportQueueService<B>>

Get handle to ImportQueueService.

fn service_ref(&mut self) -> &mut dyn ImportQueueService<B>

Get a reference to the handle to ImportQueueService.

fn poll_actions(&mut self, cx: &mut Context<'_>, link: &dyn Link<B>)

Poll actions from network.

fn run<'life0, 'async_trait>( self, link: &'life0 dyn Link<B>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Start asynchronous runner for import queue.

Takes an object implementing Link which allows the import queue to influence the synchronization process.