Trait ChainReadChannelOperations 

pub trait ChainReadChannelOperations {
    type Error: Error + Send + Sync + 'static;

    // Required methods
    fn me(&self) -> &Address;
    fn channel_by_id<'life0, 'life1, 'async_trait>(
        &'life0 self,
        channel_id: &'life1 HashBase<CoreWrapper<Keccak256Core>>,
    ) -> Pin<Box<dyn Future<Output = Result<Option<ChannelEntry>, Self::Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             'life1: 'async_trait,
             Self: 'async_trait;
    fn stream_channels<'a, 'async_trait>(
        &'a self,
        selector: ChannelSelector,
    ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = ChannelEntry> + Send + 'a>>, Self::Error>> + Send + 'async_trait>>
       where 'a: 'async_trait,
             Self: 'async_trait;

    // Provided method
    fn channel_by_parties<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        src: &'life1 Address,
        dst: &'life2 Address,
    ) -> Pin<Box<dyn Future<Output = Result<Option<ChannelEntry>, Self::Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             Self: Sync + 'async_trait { ... }
}

On-chain read operations regarding channels.

Required Associated Types

type Error: Error + Send + Sync + 'static

Required Methods

fn me(&self) -> &Address

Returns on-chain Address of the current node.

fn channel_by_id<'life0, 'life1, 'async_trait>( &'life0 self, channel_id: &'life1 HashBase<CoreWrapper<Keccak256Core>>, ) -> Pin<Box<dyn Future<Output = Result<Option<ChannelEntry>, Self::Error>> + Send + 'async_trait>>

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

Returns a single channel given channel_id.

fn stream_channels<'a, 'async_trait>( &'a self, selector: ChannelSelector, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = ChannelEntry> + Send + 'a>>, Self::Error>> + Send + 'async_trait>>

where 'a: 'async_trait, Self: 'async_trait,

Returns a stream of channels given the ChannelSelector.

Provided Methods

fn channel_by_parties<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, src: &'life1 Address, dst: &'life2 Address, ) -> Pin<Box<dyn Future<Output = Result<Option<ChannelEntry>, Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: Sync + 'async_trait,

Returns a single channel given src and dst.

Implementations on Foreign Types

impl<'b, T> ChainReadChannelOperations for &'b T

where T: 'b + ChainReadChannelOperations + Sync + ?Sized,

type Error = <T as ChainReadChannelOperations>::Error

fn me(&self) -> &Address

fn channel_by_parties<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, src: &'life1 Address, dst: &'life2 Address, ) -> Pin<Box<dyn Future<Output = Result<Option<ChannelEntry>, <&'b T as ChainReadChannelOperations>::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, &'b T: Sync + 'async_trait,

fn channel_by_id<'life0, 'life1, 'async_trait>( &'life0 self, channel_id: &'life1 HashBase<CoreWrapper<Keccak256Core>>, ) -> Pin<Box<dyn Future<Output = Result<Option<ChannelEntry>, <&'b T as ChainReadChannelOperations>::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, &'b T: 'async_trait,

fn stream_channels<'a, 'async_trait>( &'a self, selector: ChannelSelector, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = ChannelEntry> + Send + 'a>>, <&'b T as ChainReadChannelOperations>::Error>> + Send + 'async_trait>>

where 'a: 'async_trait, &'b T: 'async_trait,

impl<T> ChainReadChannelOperations for Box<T>

where T: ChainReadChannelOperations + Sync + ?Sized,

type Error = <T as ChainReadChannelOperations>::Error

fn me(&self) -> &Address

fn channel_by_parties<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, src: &'life1 Address, dst: &'life2 Address, ) -> Pin<Box<dyn Future<Output = Result<Option<ChannelEntry>, <Box<T> as ChainReadChannelOperations>::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Box<T>: Sync + 'async_trait,

fn channel_by_id<'life0, 'life1, 'async_trait>( &'life0 self, channel_id: &'life1 HashBase<CoreWrapper<Keccak256Core>>, ) -> Pin<Box<dyn Future<Output = Result<Option<ChannelEntry>, <Box<T> as ChainReadChannelOperations>::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Box<T>: 'async_trait,

fn stream_channels<'a, 'async_trait>( &'a self, selector: ChannelSelector, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = ChannelEntry> + Send + 'a>>, <Box<T> as ChainReadChannelOperations>::Error>> + Send + 'async_trait>>

where 'a: 'async_trait, Box<T>: 'async_trait,

impl<T> ChainReadChannelOperations for Arc<T>

where T: ChainReadChannelOperations + Sync + ?Sized,

type Error = <T as ChainReadChannelOperations>::Error

fn me(&self) -> &Address

fn channel_by_parties<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, src: &'life1 Address, dst: &'life2 Address, ) -> Pin<Box<dyn Future<Output = Result<Option<ChannelEntry>, <Arc<T> as ChainReadChannelOperations>::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Arc<T>: Sync + 'async_trait,

fn channel_by_id<'life0, 'life1, 'async_trait>( &'life0 self, channel_id: &'life1 HashBase<CoreWrapper<Keccak256Core>>, ) -> Pin<Box<dyn Future<Output = Result<Option<ChannelEntry>, <Arc<T> as ChainReadChannelOperations>::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Arc<T>: 'async_trait,

fn stream_channels<'a, 'async_trait>( &'a self, selector: ChannelSelector, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = ChannelEntry> + Send + 'a>>, <Arc<T> as ChainReadChannelOperations>::Error>> + Send + 'async_trait>>

where 'a: 'async_trait, Arc<T>: 'async_trait,

Implementors