Struct PendingSubscriptionSink 

pub struct PendingSubscriptionSink { /* private fields */ }

Represents a single subscription that is waiting to be accepted or rejected.

If this is dropped without calling PendingSubscription::reject or PendingSubscriptionSink::accept a default error is sent out as response to the subscription call.

Thus, if you want a customized error message then PendingSubscription::reject must be called.

Implementations

impl PendingSubscriptionSink

pub async fn reject(self, err: impl Into<ErrorObject<'static>>)

Reject the subscription by responding to the subscription method call with the error message from [jsonrpsee_types::error::ErrorObject].

Note

If this is used in the async subscription callback the return value is simply ignored because no further notification are propagated once reject has been called.

pub async fn accept( self, ) -> Result<SubscriptionSink, PendingSubscriptionAcceptError>

Attempt to accept the subscription and respond the subscription method call.

Errors

Fails if the connection is closed, or if the subscription response exceeds the max_response_size. In the latter case the call is answered with an oversized response error and the subscription is not registered.

pub fn subscription_id(&self) -> SubscriptionId<'static>

Get the subscription ID.

pub fn connection_id(&self) -> ConnectionId

Returns connection identifier, which was used to perform pending subscription request

pub fn capacity(&self) -> usize

Get the capacity of the channel.

pub fn max_capacity(&self) -> usize

Get the max capacity of the channel.

pub fn method_name(&self) -> &str

Get the method name.

Trait Implementations

impl Debug for PendingSubscriptionSink

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 120 bytes