Struct CalldataSource

pub struct CalldataSource<CP>
where
    CP: ChainProvider + Send,
{
    pub chain_provider: CP,
    pub batch_inbox_address: Address,
    pub signer: Address,
    pub calldata: VecDeque<Bytes>,
    pub open: bool,
}

A data iterator that reads from calldata.

Fields

chain_provider: CP

The chain provider to use for the calldata source.

batch_inbox_address: Address

The batch inbox address.

signer: Address

The L1 Signer.

calldata: VecDeque<Bytes>

Current calldata.

open: bool

Whether the calldata source is open.

Implementations

impl<CP: ChainProvider + Send> CalldataSource<CP>

pub const fn new( chain_provider: CP, batch_inbox_address: Address, signer: Address, ) -> Self

Creates a new calldata source.

Trait Implementations

impl<CP> Clone for CalldataSource<CP>

where CP: ChainProvider + Send + Clone,

fn clone(&self) -> CalldataSource<CP>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<CP: ChainProvider + Send> DataAvailabilityProvider for CalldataSource<CP>

type Item = Bytes

The item type of the data iterator.

fn next<'life0, 'life1, 'async_trait>( &'life0 mut self, block_ref: &'life1 BlockInfo, ) -> Pin<Box<dyn Future<Output = PipelineResult<Self::Item>> + Send + 'async_trait>>

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

Returns the next data for the given BlockInfo. Returns a PipelineError::Eof if there is no more data for the given block ref.

fn clear(&mut self)

Clears the data source for the next block ref.

impl<CP> Debug for CalldataSource<CP>

where CP: ChainProvider + Send + Debug,

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

Formats the value using the given formatter.