Struct sc_consensus::import_queue::BasicQueue

pub struct BasicQueue<B: BlockT, Transaction> { /* 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, Transaction: Send + 'static> BasicQueue<B, Transaction>

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

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, Transaction> Drop for BasicQueue<B, Transaction>

fn drop(&mut self)

Executes the destructor for this type.

impl<B: BlockT, Transaction: Send> ImportQueue<B> for BasicQueue<B, Transaction>

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: &mut dyn Link<B>)

Poll actions from network.

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

Start asynchronous runner for import queue.

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