Struct IpfsIndexedTransactions 

pub struct IpfsIndexedTransactions<B, C> { /* private fields */ }

Implements BlockProvider, providing access to indexed transactions in the wrapped client. Note that it isn’t possible to just implement BlockProvider on types implementing BlockBackend because BlockBackend is generic over the (chain) block type.

Implementations

impl<B, C> IndexedTransactions<B, C>

pub fn new(client: Arc<C>, num_blocks_kept: u32) -> Self

Create a new IndexedTransactions wrapper over the given client. The client is assumed to keep num_blocks_kept finalized blocks.

Trait Implementations

impl<B, C> BlockProvider for IndexedTransactions<B, C>

where B: Block, C: BlockchainEvents<B> + BlockBackend<B> + Send + Sync + 'static,

fn have(&self, multihash: &Multihash<32>) -> bool

Returns true if we have the block with the given hash.

fn get(&self, multihash: &Multihash<32>) -> Option<Vec<u8>>

Returns the block with the given hash if possible, otherwise returns None.

fn changes(&self) -> Pin<Box<dyn Stream<Item = Change> + Send>>

Returns a stream of changes to the available blocks. All blocks which are available at the point of calling will be reported as additions. Note that the stream may not be perfectly synchronised with have/get.