Trait web3::DuplexTransport

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

    fn subscribe(&self, id: &SubscriptionId) -> Self::NotificationStream;
    fn unsubscribe(&self, id: &SubscriptionId);
}

A transport implementation supporting pub sub subscriptions.

Required Associated Types

type NotificationStream: Stream<Item = Value, Error = Error>

The type of stream this transport returns

Required Methods

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

Add a subscription to this transport

fn unsubscribe(&self, id: &SubscriptionId)

Remove a subscription from this transport

Implementors

impl DuplexTransport for Ipc

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

impl DuplexTransport for WebSocket

type NotificationStream = Box<dyn Stream<Item = Value, Error = Error> + 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