Struct jsonrpsee_core::server::PendingSubscriptionSink

pub struct PendingSubscriptionSink {
    pub inner: MethodSink,
    /* private fields */
}

Available on crate feature server only.

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.

Fields

inner: MethodSink

Sink.

Implementations

impl PendingSubscriptionSink

pub async fn reject(self, err: impl Into<ErrorObjectOwned>)

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.

Panics

Panics if the subscription response exceeded the max_response_size.

pub fn connection_id(&self) -> ConnectionId

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

Trait Implementations

impl Debug for PendingSubscriptionSink

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

Formats the value using the given formatter.