Struct BlobSource

pub struct BlobSource<F, B>
where
    F: ChainProvider + Send,
    B: BlobProvider + Send,
{
    pub chain_provider: F,
    pub blob_fetcher: B,
    pub batcher_address: Address,
    pub signer: Address,
    pub data: Vec<BlobData>,
    pub open: bool,
}

A data iterator that reads from a blob.

Fields

chain_provider: F

Chain provider.

blob_fetcher: B

Fetches blobs.

batcher_address: Address

The address of the batcher contract.

signer: Address

The L1 Signer.

data: Vec<BlobData>

Data.

open: bool

Whether the source is open.

Implementations

impl<F, B> BlobSource<F, B>

where F: ChainProvider + Send, B: BlobProvider + Send,

pub const fn new( chain_provider: F, blob_fetcher: B, batcher_address: Address, signer: Address, ) -> Self

Creates a new blob source.

Trait Implementations

impl<F, B> Clone for BlobSource<F, B>

where F: ChainProvider + Send + Clone, B: BlobProvider + Send + Clone,

fn clone(&self) -> BlobSource<F, B>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<F, B> DataAvailabilityProvider for BlobSource<F, B>

where F: ChainProvider + Sync + Send, B: BlobProvider + Sync + Send,

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<F, B> Debug for BlobSource<F, B>

where F: ChainProvider + Send + Debug, B: BlobProvider + Send + Debug,

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

Formats the value using the given formatter.