Trait 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

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

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

impl<X, T> DuplexTransport for X

where T: DuplexTransport + ?Sized, X: Deref<Target = T> + Debug + Clone,

type NotificationStream = <T as DuplexTransport>::NotificationStream