zen-observable.d.ts

zen-observable.d.ts

declare module 'zen-observable' {
    export = Observable;

    class Observable<T> {
        constructor(subscriber: SubscriberFunction<T>);

        subscribe(observer: Observer<T>): Subscription;
        subscribe(observer: (value: T) => any): Subscription;
        forEach(callback: (value: T) => any): Promise<void>;
        map<U>(callback: (value: T) => U): Observable<U>;
        filter(callback: (value: T) => boolean): Observable<T>;
        reduce<U>(callback: (previousValue: T, currentValue: T) => U, initialValue?: T): Observable<U>;
        reduce<U, V>(callback: (previousValue: V, currentValue: T) => U, initialValue: V): Observable<U>;
        flatMap<U>(callback: (value: T) => Observable<U>): Observable<U>

        static of<T>(...item: T[]): Observable<T>;
        static from<T>(observable: Observable<T> | T[]): Observable<T>;
    }
    interface SubscriberFunction<T> {
        (subscriptionObserver: SubscriptionObserver<T>): (() => void) | Subscription;
    }
    interface SubscriptionObserver<T> {
        next(value: T): void;
        error(error: Error): void;
        complete(): void;
        readonly closed: boolean;
    }
    interface Observer<T> {
        start?(subscription: Subscription): void;
        next?(value: T): void;
        error?(error: Error): void;
        complete?(): void;
    }
    interface Subscription {
        unsubscribe(): void;
        readonly closed: boolean
    }
}