Trait web3::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 DuplexTransport for Ipc

type NotificationStream = UnboundedReceiverStream<Value>

impl DuplexTransport for WebSocket

type NotificationStream = UnboundedReceiver<Value>

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, Global>>

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

type NotificationStream = <T as DuplexTransport>::NotificationStream