mirror of
https://github.com/zhigang1992/DefinitelyTyped.git
synced 2026-04-22 11:57:33 +08:00
4924c77584
Generics values where incorrect. The correct result for windowWithXXX operators is Observable<Observable<T>> and for bufferWithXXX it's Observable<T[]>
84 lines
4.1 KiB
TypeScript
84 lines
4.1 KiB
TypeScript
// Type definitions for RxJS "Aggregates"
|
|
// Project: http://rx.codeplex.com/
|
|
// Definitions by: Carl de Billy <http://carl.debilly.net/>
|
|
// Definitions by: Igor Oleinikov <https://github.com/Igorbek>
|
|
// Definitions: https://github.com/borisyankov/DefinitelyTyped
|
|
|
|
///<reference path="rx.d.ts" />
|
|
|
|
declare module Rx {
|
|
|
|
export interface TimeInterval<T> {
|
|
value: T;
|
|
interval: number;
|
|
}
|
|
|
|
export interface Timestamp<T> {
|
|
value: T;
|
|
timestamp: number;
|
|
}
|
|
|
|
export interface Observable<T> {
|
|
ifThen(condition: () => boolean, thenSource: Observable<T>): Observable<T>;
|
|
ifThen(condition: () => boolean, thenSource: Observable<T>, elseSource: Observable<T>): Observable<T>;
|
|
ifThen(condition: () => boolean, thenSource: Observable<T>, scheduler: IScheduler): Observable<T>;
|
|
|
|
delay(dueTime: number, scheduler?: IScheduler): Observable<T>;
|
|
throttle(dueTime: number, scheduler?: IScheduler): Observable<T>;
|
|
windowWithTime(timeSpan: number, timeShift: number, scheduler?: IScheduler): Observable<Observable<T>>;
|
|
windowWithTime(timeSpan: number, scheduler?: IScheduler): Observable<Observable<T>>;
|
|
windowWithTimeOrCount(timeSpan: number, count: number, scheduler?: IScheduler): Observable<Observable<T>>;
|
|
bufferWithTime(timeSpan: number, timeShift: number, scheduler?: IScheduler): Observable<T[]>;
|
|
bufferWithTime(timeSpan: number, scheduler?: IScheduler): Observable<T[]>;
|
|
bufferWithTimeOrCount(timeSpan: number, count: number, scheduler?: IScheduler): Observable<T[]>;
|
|
timeInterval(scheduler?: IScheduler): Observable<TimeInterval<T>>;
|
|
timestamp(scheduler?: IScheduler): Observable<Timestamp<T>>;
|
|
sample(interval: number, scheduler?: IScheduler): Observable<T>;
|
|
sample<TSample>(sampler: Observable<TSample>, scheduler?: IScheduler): Observable<T>;
|
|
timeout(dueTime: Date, other?: Observable<T>, scheduler?: IScheduler): Observable<T>;
|
|
timeout(dueTime: number, other?: Observable<T>, scheduler?: IScheduler): Observable<T>;
|
|
|
|
delaySubscription(dueTime: number, scheduler?: IScheduler): Observable<T>;
|
|
delayWithSelector(delayDurationSelector: (item: T) => number): Observable<T>;
|
|
delayWithSelector(subscriptionDelay: number, delayDurationSelector: (item: T) => number): Observable<T>;
|
|
|
|
timeoutWithSelector<TTimeout>(firstTimeout: Observable<TTimeout>, timeoutdurationSelector?: (item: T) => Observable<TTimeout>, other?: Observable<T>): Observable<T>;
|
|
throttleWithSelector<TTimeout>(throttleDurationSelector: (item: T) => Observable<TTimeout>): Observable<T>;
|
|
|
|
skipLastWithTime(duration: number, scheduler?: IScheduler): Observable<T>;
|
|
takeLastWithTime(duration: number, timerScheduler?: IScheduler, loopScheduler?: IScheduler): Observable<T>;
|
|
|
|
takeLastBufferWithTime(duration: number, scheduler?: IScheduler): Observable<T[]>;
|
|
takeWithTime(duration: number, scheduler?: IScheduler): Observable<T>;
|
|
skipWithTime(duration: number, scheduler?: IScheduler): Observable<T>;
|
|
|
|
skipUntilWithTime(startTime: Date, scheduler?: IScheduler): Observable<T>;
|
|
takeUntilWithTime(endTime: Date, scheduler?: IScheduler): Observable<T>;
|
|
}
|
|
|
|
interface ObservableStatic {
|
|
interval(period: number, scheduler?: IScheduler): Observable<number>;
|
|
interval(dutTime: number, period: number, scheduler?: IScheduler): Observable<number>;
|
|
timer(dueTime: Date, period: number, scheduler: IScheduler): Observable<number>;
|
|
timer(dueTime: Date, scheduler: IScheduler): Observable<number>;
|
|
timer(dueTime: number, period: number, scheduler: IScheduler): Observable<number>;
|
|
timer(dueTime: number, scheduler: IScheduler): Observable<number>;
|
|
|
|
generateWithAbsoluteTime<TState, TResult>(
|
|
initialState: TState,
|
|
condition: (state: TState) => boolean,
|
|
iterate: (state: TState) => TState,
|
|
resultSelector: (state: TState) => TResult,
|
|
timeSelector: (state: TState) => Date,
|
|
scheduler?: IScheduler): Observable<TResult>;
|
|
|
|
generateWithRelativeTime<TState, TResult>(
|
|
initialState: TState,
|
|
condition: (state: TState) => boolean,
|
|
iterate: (state: TState) => TState,
|
|
resultSelector: (state: TState) => TResult,
|
|
timeSelector: (state: TState) => number,
|
|
scheduler?: IScheduler): Observable<TResult>;
|
|
}
|
|
}
|