[−][src]Struct jsonrpc_pubsub::Subscriber
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]
method: T
) -> (Self, Receiver<Result<SubscriptionId, Error>>, Receiver<String>)
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]
self,
id: SubscriptionId
) -> impl Future<Item = Sink, Error = ()>
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
Auto Trait Implementations
impl Send for Subscriber
impl Sync for Subscriber
Blanket Implementations
impl<T> From for T[src]
impl<T, U> Into for T where
U: From<T>, [src]
U: From<T>,
impl<T, U> TryFrom for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T> Borrow for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> BorrowMut for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T, U> TryInto for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.