Struct ChannelAssembler

pub struct ChannelAssembler<P>
where
    P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug,
{ /* private fields */ }

The ChannelAssembler stage is responsible for assembling the Frames from the FrameQueue stage into a raw compressed Channel.

Implementations

impl<P> ChannelAssembler<P>

where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug,

pub const fn new(cfg: Arc<RollupConfig>, prev: P) -> Self

Creates a new ChannelAssembler stage with the given configuration and previous stage.

pub fn is_timed_out(&self) -> PipelineResult<bool>

Returns whether or not the channel currently being assembled has timed out.

Trait Implementations

impl<P> ChannelReaderProvider for ChannelAssembler<P>

where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

fn next_data<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = PipelineResult<Option<Bytes>>> + Send + 'async_trait>>

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

Pulls the next piece of data from the channel bank. Note that it attempts to pull data out of the channel bank prior to loading data in (unlike most other stages). This is to ensure maintain consistency around channel bank pruning which depends upon the order of operations.

impl<P> Debug for ChannelAssembler<P>

where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<P> OriginAdvancer for ChannelAssembler<P>

where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

fn advance_origin<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = PipelineResult<()>> + Send + 'async_trait>>

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

Advances the internal state of the lowest stage to the next l1 origin. This method is the equivalent of the reference implementation advance_l1_block.

impl<P> OriginProvider for ChannelAssembler<P>

where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Debug,

fn origin(&self) -> Option<BlockInfo>

Returns the optional L1 BlockInfo origin.

impl<P> SignalReceiver for ChannelAssembler<P>

where P: NextFrameProvider + OriginAdvancer + OriginProvider + SignalReceiver + Send + Debug,

fn signal<'life0, 'async_trait>( &'life0 mut self, signal: Signal, ) -> Pin<Box<dyn Future<Output = PipelineResult<()>> + Send + 'async_trait>>

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

Receives a signal from the driver.