[−][src]Struct jsonrpc_pubsub::typed::Subscriber
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>>, UnboundedReceiver<String>)[src]
method: M
) -> (Self, Receiver<Result<SubscriptionId, Error>>, UnboundedReceiver<String>)
Create new subscriber for tests.
pub fn reject(self, error: Error) -> Result<(), ()>[src]
Reject subscription with given error.
pub async fn reject_async(self, error: Error) -> Result<(), ()>[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 async fn assign_id_async(self, id: SubscriptionId) -> Result<Sink<T, E>, ()>[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>[src]
impl<T, E> Send for Subscriber<T, E> where
E: Send,
T: Send, [src]
E: Send,
T: Send,
impl<T, E> Sync for Subscriber<T, E> where
E: Sync,
T: Sync, [src]
E: Sync,
T: Sync,
impl<T, E> Unpin for Subscriber<T, E> where
E: Unpin,
T: Unpin, [src]
E: Unpin,
T: Unpin,
impl<T, E = Error> !UnwindSafe for Subscriber<T, E>[src]
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,
pub 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.
pub 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.
pub 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>,