Trait ic_web3::DuplexTransport

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

    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>,
    X: Debug,
    X: Clone,

type NotificationStream = <T as DuplexTransport>::NotificationStream