Struct ActiveSubscription 

pub struct ActiveSubscription {
    pub sub_id: String,
    /* private fields */
}

FFI-compatible ActiveSubscription

Fields

sub_id: String

Implementations

impl ActiveSubscription

pub fn id(&self) -> String

Get the subscription ID

pub async fn recv(&self) -> Result<NotificationPayload, FfiError>

Receive the next notification

pub async fn try_recv(&self) -> Result<Option<NotificationPayload>, FfiError>

Try to receive a notification without blocking

Trait Implementations

impl<UT> LiftRef<UT> for ActiveSubscription

type LiftType = Arc<ActiveSubscription>

impl<UT> LowerError<UT> for ActiveSubscription

fn lower_error(obj: Self) -> RustBuffer

Lower this value for scaffolding function return

impl<UT> LowerReturn<UT> for ActiveSubscription

type ReturnType = <Arc<ActiveSubscription> as LowerReturn<UniFfiTag>>::ReturnType

The type that should be returned by scaffolding functions for this type.

fn lower_return(obj: Self) -> Result<Self::ReturnType, RustCallError>

Lower the return value from an scaffolding call

fn handle_failed_lift( error: LiftArgsError, ) -> Result<Self::ReturnType, RustCallError>

Lower the return value for failed argument lifts

impl<UT> TypeId<UT> for ActiveSubscription

const TYPE_ID_META: MetadataBuffer