[−][src]Struct jsonrpc_pubsub::typed::Subscriber
New PUB-SUB subscriber.
Methods
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]
method: M
) -> (Self, Receiver<Result<SubscriptionId, Error>>, Receiver<String>)
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]
self,
id: SubscriptionId
) -> impl Future<Item = Sink<T, E>, Error = ()>
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> Unpin for Subscriber<T, E> where
E: Unpin,
T: Unpin,
E: Unpin,
T: Unpin,
impl<T, E> Sync for Subscriber<T, E> where
E: Sync,
T: Sync,
E: Sync,
T: Sync,
impl<T, E> Send for Subscriber<T, E> where
E: Send,
T: Send,
E: Send,
T: Send,
impl<T, E = Error> !UnwindSafe for Subscriber<T, E>
impl<T, E = Error> !RefUnwindSafe for Subscriber<T, E>
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,