Trait FrameQueueProvider

pub trait FrameQueueProvider {
    type Item: Into<Bytes>;

    // Required method
    fn next_data<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<Self::Item, PipelineErrorKind>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             Self: 'async_trait;
}

Provides data frames for the FrameQueue stage.

Required Associated Types

type Item: Into<Bytes>

An item that can be converted into a byte array.

Required Methods

fn next_data<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Self::Item, PipelineErrorKind>> + Send + 'async_trait>>

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

Retrieves the next data item from the L1 retrieval stage. If there is data, it pushes it into the next stage. If there is no data, it returns an error.

Implementors

impl<DAP, P> FrameQueueProvider for L1Retrieval<DAP, P>

where DAP: DataAvailabilityProvider + Send, P: L1RetrievalProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send,

type Item = <DAP as DataAvailabilityProvider>::Item