wassname/DefinitelyTyped
1
0
Fork 0
mirror of https://github.com/wassname/DefinitelyTyped.git synced 2026-09-09 11:13:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

Rx.JS: fixed for 0.9.1.1

Browse Source
This commit is contained in:
gstamac
2013-08-25 12:54:01 +02:00
parent f942d086b0
commit 0790572094
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rx.js/rx.js.binding.d.ts
Vendored
+1 -1
View File
@@ -16,7 +16,7 @@ declare module Rx {
}
interface BehaviorSubject<T> extends ISubject<T> {
new (initialValue: T): BehaviorSubject;
new (initialValue: T): BehaviorSubject<any>;
}
interface ConnectableObservable<T> extends IObservable<T>{
rx.js/rx.js.d.ts
Vendored
+7 -7
View File
@@ -199,7 +199,7 @@ declare module Rx {
interface INotification<T> {
accept(observer: IObserver<T>): void;
accept(onNext: (value: T) =>void , onError?: (exception: any) =>void , onCompleted?: () =>void ): void;
toObservable(scheduler?: IScheduler): IObservable;
toObservable(scheduler?: IScheduler): IObservable<any>;
hasValue: boolean;
equals(other: INotification<T>): boolean;
kind: string;
@@ -240,7 +240,7 @@ declare module Rx {
export interface Enumerable<T> {
(getEnumerator: () =>IEnumerator<T>): IEnumerable<T>;
repeat(value: T, repeatCount?: number): IEnumerable;
repeat(value: T, repeatCount?: number): IEnumerable<any>;
forEach<T2>(source: T[], selector?: (element: T, index: number) => T2): IEnumerable<T2>;
forEach<T2>(source: { length: number; [index: number]: T; }, selector?: (element: T, index: number) => T2): IEnumerable<T2>;
}
@@ -254,7 +254,7 @@ declare module Rx {
toNotifier(): (notification: INotification<T>) =>void;
asObserver(): IObserver<T>;
checked(): ICheckedObserver;
checked(): ICheckedObserver<any>;
}
export module Observer {
//abstract
@@ -332,7 +332,7 @@ declare module Rx {
//concatIObservable(): IObservable<T>;
merge(maxConcurrent: number): IObservable<T>;
merge(other: IObservable<T>): IObservable<T>;
//mergeIObservable(): IObservable;
//mergeIObservable(): IObservable<any>;
onErrorResumeNext(second: IObservable<T>): IObservable<T>;
skipUntil<T2>(other: IObservable<T2>): IObservable<T>;
switchLatest(): IObservable<T>;
@@ -343,10 +343,10 @@ declare module Rx {
zip<T2, T3, T4, T5, TResult>(second: IObservable<T2>, third: IObservable<T3>, fourth: IObservable<T4>, fifth: IObservable<T5>, resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult): IObservable<TResult>;
zip<TResult>(...soucesAndResultSelector: any[]): IObservable<TResult>;
zip<TResult>(second: any[], resultSelector: (left: T, right: any) => TResult): IObservable<TResult>;
asIObservable(): IObservable;
asIObservable(): IObservable<any>;
bufferWithCount(count: number, skip?: number): IObservable<T>;
dematerialize<TOrigin>(): IObservable<TOrigin>;
distinctUntilChanged<TValue>(keySelector?: (value: T) => TValue, comparer?: (x: TValue, y: TValue) =>boolean): IObservable;
distinctUntilChanged<TValue>(keySelector?: (value: T) => TValue, comparer?: (x: TValue, y: TValue) =>boolean): IObservable<any>;
doAction(observer: IObserver<T>): IObservable<T>;
doAction(onNext: (value: T) => void , onError?: (exception: any) =>void , onCompleted?: () =>void ): IObservable<T>;
finallyAction(action: () =>void): IObservable<T>;
@@ -377,7 +377,7 @@ declare module Rx {
}
interface Observable {
(subscribe: (observer: IObserver<any>) =>_IDisposable): IObservable;
(subscribe: (observer: IObserver<any>) =>_IDisposable): IObservable<any>;
start<T>(func: () =>T, scheduler?: IScheduler, context?: any): IObservable<T>;
toAsync<T>(func: Function, scheduler?: IScheduler, context?: any): (...arguments: any[]) => IObservable<T>;