[−][src]Struct jsonrpc_pubsub::Subscriber
Represents a subscribing client. Subscription handlers can either reject this subscription request or assign an unique id.
Implementations
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 !RefUnwindSafe for Subscriber
impl Send for Subscriber
impl Sync for Subscriber
impl Unpin for Subscriber
impl !UnwindSafe for Subscriber
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
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<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,