/** @packageDocumentation * @module Tree */ import { Observable as RxjsObservable } from "rxjs/internal/Observable"; /** * Helper method that creates an Observable from Iterable or Promise. * @public */ export declare function from(iterable: Iterable | PromiseLike): Observable; /** @internal */ export declare function toRxjsObservable(observable: Observable): RxjsObservable; /** * Observable interface compatible with [rxjs](https://github.com/ReactiveX/rxjs) * This interface ensures that consumers are not required to have rxjs as dependency. * @public */ export interface Observable extends Subscribable { } /** * Subscribable interface compatible with [rxjs](https://github.com/ReactiveX/rxjs) * This interface ensures that consumers are not required to have rxjs as dependency. * @public */ export interface Subscribable { subscribe(observer?: Observer): Subscription; subscribe(next: null | undefined, error: null | undefined, complete: () => void): Subscription; subscribe(next: null | undefined, error: (error: any) => void, complete?: () => void): Subscription; subscribe(next: (value: T) => void, error: null | undefined, complete: () => void): Subscription; subscribe(next?: (value: T) => void, error?: (error: any) => void, complete?: () => void): Subscription; } /** * Observer interface compatible with [rxjs](https://github.com/ReactiveX/rxjs) * This interface ensures that consumers are not required to have rxjs as dependency. * @public */ export declare type Observer = NextObserver | ErrorObserver | CompletionObserver; /** * Unsubscribable interface compatible with [rxjs](https://github.com/ReactiveX/rxjs) * This interface ensures that consumers are not required to have rxjs as dependency. * @public */ export interface Unsubscribable { unsubscribe(): void; } /** * Subscription interface compatible with [rxjs](https://github.com/ReactiveX/rxjs) * This interface ensures that consumers are not required to have rxjs as dependency. * @public */ export interface Subscription extends Unsubscribable { readonly closed: boolean; unsubscribe(): void; add(tearDown: Unsubscribable | (() => void) | void): void; } /** * NextObserver interface compatible with [rxjs](https://github.com/ReactiveX/rxjs) * This interface ensures that consumers are not required to have rxjs as dependency. * @public */ export interface NextObserver { closed?: boolean; next: (value: T) => void; error?: (err: any) => void; complete?: () => void; } /** * ErrorObserver interface compatible with [rxjs](https://github.com/ReactiveX/rxjs) * This interface ensures that consumers are not required to have rxjs as dependency. * @public */ export interface ErrorObserver { closed?: boolean; next?: (value: T) => void; error: (err: any) => void; complete?: () => void; } /** * CompletionObserver interface compatible with [rxjs](https://github.com/ReactiveX/rxjs) * This interface ensures that consumers are not required to have rxjs as dependency. * @public */ export interface CompletionObserver { closed?: boolean; next?: (value: T) => void; error?: (err: any) => void; complete: () => void; } //# sourceMappingURL=Observable.d.ts.map