Trait PubsubClient

pub trait PubsubClient: JsonRpcClient {
    type NotificationStream: Stream<Item = Box<RawValue>> + Send + Unpin;

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

A transport implementation supporting pub sub subscriptions.

Required Associated Types

type NotificationStream: Stream<Item = Box<RawValue>> + Send + Unpin

The type of stream this transport returns

Required Methods

fn subscribe<T: Into<U256>>( &self, id: T, ) -> Result<Self::NotificationStream, Self::Error>

Add a subscription to this transport

fn unsubscribe<T: Into<U256>>(&self, id: T) -> Result<(), Self::Error>

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 PubsubClient for Ipc

Available on crate feature ipc and (Unix or Windows) only.

type NotificationStream = UnboundedReceiver<Box<RawValue>>

impl PubsubClient for Ws

Available on crate feature legacy-ws only.

type NotificationStream = UnboundedReceiver<Box<RawValue>>

impl<C> PubsubClient for QuorumProvider<C>

where C: PubsubClientWrapper,

type NotificationStream = QuorumStream