Trait ic_web3_rs::DuplexTransport

pub trait DuplexTransport: Transport {
    type NotificationStream: Stream<Item = Value>;

    // Required methods
    fn subscribe(&self, id: SubscriptionId) -> Result<Self::NotificationStream>;
    fn unsubscribe(&self, id: SubscriptionId) -> Result<()>;
}

A transport implementation supporting pub sub subscriptions.

Required Associated Types

type NotificationStream: Stream<Item = Value>

The type of stream this transport returns

Required Methods

fn subscribe(&self, id: SubscriptionId) -> Result<Self::NotificationStream>

Add a subscription to this transport

fn unsubscribe(&self, id: SubscriptionId) -> Result<()>

Remove a subscription from this transport

Implementors

impl<A, B, AStream, BStream> DuplexTransport for Either<A, B>where A: DuplexTransport<NotificationStream = AStream>, B: DuplexTransport<NotificationStream = BStream>, A::Out: 'static + Send, B::Out: 'static + Send, AStream: Stream<Item = Value> + 'static + Send, BStream: Stream<Item = Value> + 'static + Send,

type NotificationStream = Pin<Box<dyn Stream<Item = Value> + Send + 'static, Global>>

impl<X, T> DuplexTransport for Xwhere T: DuplexTransport + ?Sized, X: Deref<Target = T> + Debug + Clone,

type NotificationStream = <T as DuplexTransport>::NotificationStream