Class Observable<T>

new Observable<T = any>(subscriber: SubscriberFunction<T>): Observable<T>

"[asyncIterator]"(): AsyncGenerator<Awaited<T>, void, unknown>

"[observable]"(): Observable<T>

subscribe(
    onNext: (value: T) => void,
    onError?: (reason: string | Error) => void,
    onComplete?: () => void,
): { unsubscribe: () => boolean; get closed(): boolean }

toPromise(): Promise<T>

from<T = any>(
    observable:
        | Iterable<T, any, any>
        | AsyncIterable<T, any, any>
        | Subscribable<T>,
): Observable<T>

fromEvent<T = any>(target: EventTrigger, name: string): Observable<T>

fromStream<T>(
    list: Iterable<T, any, any> | AsyncIterable<T, any, any>,
): Observable<T>

of<T = any>(...items: T[]): Observable<T>