/// <reference types="rx-lite" />

declare namespace Rx {
    interface Observable<T> {
        finalValue(): Observable<T>;
        aggregate(accumulator: (acc: T, value: T) => T): Observable<T>;
        aggregate<TAcc>(seed: TAcc, accumulator: (acc: TAcc, value: T) => TAcc): Observable<TAcc>;

        reduce(accumulator: (acc: T, value: T) => T): Observable<T>;
        reduce<TAcc>(accumulator: (acc: TAcc, value: T) => TAcc, seed: TAcc): Observable<TAcc>;

        any(
            predicate?: (value: T, index: number, source: Observable<T>) => boolean,
            thisArg?: any,
        ): Observable<boolean>;
        some(
            predicate?: (value: T, index: number, source: Observable<T>) => boolean,
            thisArg?: any,
        ): Observable<boolean>; // alias for any

        isEmpty(): Observable<boolean>;
        all(predicate?: (value: T) => boolean, thisArg?: any): Observable<boolean>;
        every(predicate?: (value: T) => boolean, thisArg?: any): Observable<boolean>; // alias for all
        contains(value: T): Observable<boolean>;
        contains<TOther>(value: TOther, comparer: (value1: T, value2: TOther) => boolean): Observable<boolean>;
        count(
            predicate?: (value: T, index: number, source: Observable<T>) => boolean,
            thisArg?: any,
        ): Observable<number>;
        sum(
            keySelector?: (value: T, index: number, source: Observable<T>) => number,
            thisArg?: any,
        ): Observable<number>;
        minBy<TKey>(keySelector: (item: T) => TKey, comparer: (value1: TKey, value2: TKey) => number): Observable<T>;
        minBy(keySelector: (item: T) => number): Observable<T>;
        min(comparer?: (value1: T, value2: T) => number): Observable<T>;
        maxBy<TKey>(keySelector: (item: T) => TKey, comparer: (value1: TKey, value2: TKey) => number): Observable<T>;
        maxBy(keySelector: (item: T) => number): Observable<T>;
        max(comparer?: (value1: T, value2: T) => number): Observable<number>;
        average(
            keySelector?: (value: T, index: number, source: Observable<T>) => number,
            thisArg?: any,
        ): Observable<number>;

        sequenceEqual<TOther>(
            second: Observable<TOther>,
            comparer: (value1: T, value2: TOther) => number,
        ): Observable<boolean>;
        sequenceEqual<TOther>(
            second: IPromise<TOther>,
            comparer: (value1: T, value2: TOther) => number,
        ): Observable<boolean>;
        sequenceEqual(second: Observable<T>): Observable<boolean>;
        sequenceEqual(second: IPromise<T>): Observable<boolean>;
        sequenceEqual<TOther>(second: TOther[], comparer: (value1: T, value2: TOther) => number): Observable<boolean>;
        sequenceEqual(second: T[]): Observable<boolean>;

        elementAt(index: number): Observable<T>;
        single(predicate?: (value: T, index: number, source: Observable<T>) => boolean, thisArg?: any): Observable<T>;
        first(predicate?: (value: T, index: number, source: Observable<T>) => boolean, thisArg?: any): Observable<T>;
        last(predicate?: (value: T, index: number, source: Observable<T>) => boolean, thisArg?: any): Observable<T>;
        find(predicate: (value: T, index: number, source: Observable<T>) => boolean, thisArg?: any): Observable<T>;
        findIndex(
            predicate: (value: T, index: number, source: Observable<T>) => boolean,
            thisArg?: any,
        ): Observable<number>;
    }
}

declare module "rx-lite-aggregates" {
    export = Rx;
}