Struct eth_state_client_lib::GrpcStateFoldClient

pub struct GrpcStateFoldClient<I, S> { /* private fields */ }

Implementations

impl<I, S> GrpcStateFoldClient<I, S>

pub fn new_from_channel(channel: Channel, config: &SCConfig) -> Self

Trait Implementations

impl<I, S> BlockServer for GrpcStateFoldClient<I, S>where I: Send + Sync, S: Send + Sync,

fn query_block<'life0, 'async_trait>( &'life0 self, query_block: impl 'async_trait + Into<QueryBlock> + Send + 'static ) -> Pin<Box<dyn Future<Output = Result<Arc<Block>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn query_blocks_since<'life0, 'async_trait>( &'life0 self, previous_block_hash: H256, depth: usize ) -> Pin<Box<dyn Future<Output = Result<BlocksSince>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn subscribe_blocks<'life0, 'async_trait>( &'life0 self, confirmations: usize ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<BlockStreamItem>> + Send>>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

impl<I, S> StateServer for GrpcStateFoldClient<I, S>where I: Serialize + Send + Sync, S: DeserializeOwned + Send + Sync,

type InitialState = I

type State = S

fn query_state<'life0, 'life1, 'async_trait>( &'life0 self, initial_state: &'life1 Self::InitialState, query_block: impl 'async_trait + Into<QueryBlock> + Send + 'static ) -> Pin<Box<dyn Future<Output = Result<BlockState<Self::State>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn query_states_since<'life0, 'life1, 'async_trait>( &'life0 self, initial_state: &'life1 Self::InitialState, previous_block_hash: H256, depth: usize ) -> Pin<Box<dyn Future<Output = Result<StatesSince<Self::State>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn subscribe_states<'life0, 'life1, 'async_trait>( &'life0 self, initial_state: &'life1 Self::InitialState, confirmations: usize ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<StateStreamItem<Self::State>>> + Send>>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,