[−][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 Unpin for Subscriber
impl Sync for Subscriber
impl Send for Subscriber
impl !UnwindSafe for Subscriber
impl !RefUnwindSafe for Subscriber
Blanket Implementations
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> 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, U> TryInto<U> 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.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,