default | /mod.ts | subscription@2.0.1

class default

import { default } from "https://deno.land/x/subscription@2.0.1/mod.ts";

A subscribable event.

Type Parameters

optional

T extends unknown[] = []

private

readonly

_subscriptions: Map<Subscription<T>, boolean>

The listeners that are currently subscribed to the event.

async(): AsyncIterableIterator<T> & { close(): Promise<void>; }

Get an async iterator.

dispatch(...args: T)

Fire the event and call all subscriptions.

pull(): Promise<T>

Pull the next dispatch from the event return the dispatched data.

subscribe(...listeners: Subscription<T>[]): this

Subscribe to the event.

Subscribe to the event once.

unsubscribe(...listeners: Subscription<T>[]): this

Unsubscribe to the event.