Struct jsonrpc_pubsub::typed::Subscriber

pub struct Subscriber<T, E = Error> { /* fields omitted */ }

New PUB-SUB subscriber.

Implementations

impl<T, E> Subscriber<T, E>

pub fn new(subscriber: Subscriber) -> Self

Wrap non-typed subscriber.

pub fn new_test<M: Into<String>>(
    method: M
) -> (Self, Receiver<Result<SubscriptionId, Error>>, UnboundedReceiver<String>)

Create new subscriber for tests.

pub fn reject(self, error: Error) -> Result<(), ()>

Reject subscription with given error.

pub async fn reject_async(self, error: Error) -> Result<(), ()>

Reject subscription with given error.

The returned future will resolve when the response is sent to the client.

pub fn assign_id(self, id: SubscriptionId) -> Result<Sink<T, E>, ()>

Assign id to this subscriber. This method consumes Subscriber and returns Sink if the connection is still open or error otherwise.

pub async fn assign_id_async(self, id: SubscriptionId) -> Result<Sink<T, E>, ()>

Assign id to this subscriber. This method consumes Subscriber and resolves to Sink if the connection is still open and the id has been sent or to error otherwise.

Trait Implementations

impl<T: Debug, E: Debug> Debug for Subscriber<T, E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.