Trait Pipeline

pub trait Pipeline: OriginProvider + Iterator<Item = OpAttributesWithParent> {
    // Required methods
    fn peek(&self) -> Option<&OpAttributesWithParent>;
    fn step<'life0, 'async_trait>(
        &'life0 mut self,
        cursor: L2BlockInfo,
    ) -> Pin<Box<dyn Future<Output = StepResult> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

This trait defines the interface for interacting with the derivation pipeline.

Required Methods

fn peek(&self) -> Option<&OpAttributesWithParent>

Peeks at the next OpAttributesWithParent from the pipeline.

fn step<'life0, 'async_trait>( &'life0 mut self, cursor: L2BlockInfo, ) -> Pin<Box<dyn Future<Output = StepResult> + Send + 'async_trait>>

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

Attempts to progress the pipeline.

Implementors

impl<S, P> Pipeline for DerivationPipeline<S, P>

where S: NextAttributes + SignalReceiver + OriginProvider + OriginAdvancer + Debug + Send + Sync, P: L2ChainProvider + Send + Sync + Debug,