Struct DumbBlockStreamer

pub struct DumbBlockStreamer { /* private fields */ }

Dumb block streamer

Implementations

impl DumbBlockStreamer

pub fn new() -> Self

Factory - the resulting streamer can be polled one time for each list of blocks given

pub fn set_last_polled_point(self, raw_point: Option<RawCardanoPoint>) -> Self

Set the last polled point to return when Self::last_polled_point is called

pub fn forwards(self, blocks: Vec<Vec<ScannedBlock>>) -> Self

Add to the streamer several ChainScannedBlocks::RollForwards responses at the end of its queue.

pub fn rollback(self, chain_point: ChainPoint) -> Self

Add to the streamer a ChainScannedBlocks::RollBackward response at the end of its queue.

Trait Implementations

impl BlockStreamer for DumbBlockStreamer

fn poll_next<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StdResult<Option<ChainScannedBlocks>>> + Send + 'async_trait>>

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

Stream the next available blocks

fn last_polled_point(&self) -> Option<RawCardanoPoint>

Get the last polled point of the chain

impl Clone for DumbBlockStreamer

fn clone(&self) -> DumbBlockStreamer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for DumbBlockStreamer

fn default() -> Self

Returns the “default value” for a type.