Struct ModernResourceDelivery 

pub(super) struct ModernResourceDelivery {
    handle: String,
    inner: Mutex<ModernResourceInner>,
    _permit: Arc<OwnedSemaphorePermit>,
}

Fields

handle: String

inner: Mutex<ModernResourceInner>

_permit: Arc<OwnedSemaphorePermit>

Implementations

impl ModernResourceDelivery

pub(super) fn new(handle: String, permit: Arc<OwnedSemaphorePermit>) -> Self

pub fn enqueue(&self, event: Value) -> Option<PendingModernNotification>

Queue one already-authorized event. At most one notification future may be pending per handle; additional pushes remain visible through read and are coalesced behind that notification.

pub async fn send_pending_notification(&self, work: PendingModernNotification)

pub(super) fn attach_listener( &self, sink: SubscriptionSink, ) -> Result<(u64, CancellationToken, Option<PendingModernNotification>), String>

pub(super) fn detach_listener_if(&self, listener_token: u64)

pub(super) fn close(&self)

pub(super) fn drain(&self) -> Result<(Vec<Value>, u64), String>

pub(super) fn lock_inner(&self) -> MutexGuard<'_, ModernResourceInner>