Struct kayrx::jrpc::raw::client::RawClientActiveSubscription

pub struct RawClientActiveSubscription<'a, R> { /* fields omitted */ }

Access to a subscription within a RawClient.

Methods

impl<'a, R> RawClientActiveSubscription<'a, R> where
    R: TransportClient, 

pub async fn next_notification<'_>(
    &'_ mut self
) -> Result<JsonValue, RawClientError<R::Error>>

Returns a Future that resolves when the server sends back a notification for this subscription.

Note: While this function is waiting, all the other responses and pubsub events returned by the server will be buffered up to a certain limit. Once this limit is reached, server notifications will be discarded. If you want to be sure to catch all notifications, use next_event instead.

pub fn is_closing(&self) -> bool

Returns true if we called close earlier on this subscription and we are waiting for the server to respond to our close request.

pub async fn close<'_>(
    &'_ mut self,
    method_name: impl Into<String>
) -> Result<(), CloseError<R::Error>>

Starts closing an open subscription by performing an RPC call with the given method name.

Calling this method multiple times with the same subscription will yield an error.

Note that, for convenience, we will consider the subscription closed even the server returns an error to the unsubscription request.

Trait Implementations

impl<'a, R: Debug> Debug for RawClientActiveSubscription<'a, R>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.