[][src]Struct susy_jsonrpc_pubsub::Subscriber

pub struct Subscriber { /* fields omitted */ }

Represents a subscribing client. Subscription handlers can either reject this subscription request or assign an unique id.

Methods

impl Subscriber[src]

pub fn new_test<T: Into<String>>(
    method: T
) -> (Self, Receiver<Result<SubscriptionId, Error>>, Receiver<String>)
[src]

Creates new subscriber.

Should only be used for tests.

pub fn assign_id(self, id: SubscriptionId) -> Result<Sink, ()>[src]

Consumes Subscriber and assigns unique id to a requestor.

Returns Err if request has already terminated.

pub fn assign_id_async(
    self,
    id: SubscriptionId
) -> impl Future<Item = Sink, Error = ()>
[src]

Consumes Subscriber and assigns unique id to a requestor.

The returned Future resolves when the subscriber receives subscription id. Resolves to Err if request has already terminated.

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

Rejects this subscription request with given error.

Returns Err if request has already terminated.

pub fn reject_async(self, error: Error) -> impl Future<Item = (), Error = ()>[src]

Rejects this subscription request with given error.

The returned Future resolves when the rejection is sent to the client. Resolves to Err if request has already terminated.

Trait Implementations

impl Debug for Subscriber[src]

Auto Trait Implementations

impl Send for Subscriber

impl Sync for Subscriber

Blanket Implementations

impl<T, U> Into for T where
    U: From<T>, 
[src]

impl<T> From for T[src]

impl<T, U> TryFrom for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T> Borrow for T where
    T: ?Sized
[src]

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> BorrowMut for T where
    T: ?Sized
[src]

impl<T, U> TryInto for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> Erased for T