default | /packages/plugin-smart-subscriptions/manager/index.ts | pothos@release-1725695129

class default

implements AsyncIterator<object>

import { default } from "https://deno.land/x/pothos@release-1725695129/packages/plugin-smart-subscriptions/manager/index.ts";

Constructors

new

default(unnamed 0: { value: object; debounceDelay?: number | null; subscribe: (name: string, cb: (err: unknown, data: unknown) => void) => Promise<void> | void; unsubscribe: (name: string) => Promise<void> | void; })

Properties

activeOptions: Map<string, RegisterOptions[]>

activeSubscriptions: Set<string>

debounceDelay: number | null

debounceRef: Timer | null

nextOptions: Map<string, RegisterOptions[]>

nextSubscriptions: Set<string>

pendingError: unknown

pendingEvent: boolean

pendingEvents: [string, unknown][]

rejectNext: ((err: unknown) => void) | null

resolveNext: ((done?: boolean) => void) | null

stopped: boolean

subscribeToName: (name: string, cb: (err: unknown, data: unknown) => void) => Promise<void> | void

unsubscribeFromName: (name: string) => Promise<void> | void

value: object

Methods

private

addOptions(name: string, options: RegisterOptions)

private

filterValue(name: string, value: unknown)

private

handleValue(name: string, value: unknown)

private

pushValue()

private

stop()

handleError(err: unknown)

next(): Promise<IteratorResult<object>>

return()

throw(error: unknown)

[Symbol.asyncIterator]()