Struct jsonrpc_pubsub::typed::Subscriber[][src]

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

New PUB-SUB subscriber.

Implementations

impl<T, E> Subscriber<T, E>[src]

pub fn new(subscriber: Subscriber) -> Self[src]

Wrap non-typed subscriber.

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

Create new subscriber for tests.

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

Reject subscription with given error.

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

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>, ()>[src]

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

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

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>[src]

Auto Trait Implementations

impl<T, E = Error> !RefUnwindSafe for Subscriber<T, E>

impl<T, E> Send for Subscriber<T, E> where
    E: Send,
    T: Send

impl<T, E> Sync for Subscriber<T, E> where
    E: Sync,
    T: Sync

impl<T, E> Unpin for Subscriber<T, E> where
    E: Unpin,
    T: Unpin

impl<T, E = Error> !UnwindSafe for Subscriber<T, E>

Blanket Implementations

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

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

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

impl<T> From<T> for T[src]

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

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

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> 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<V, T> VZip<V> for T where
    V: MultiLane<T>, 
[src]