Added rx.testing.d.ts: TestScheduler, ReactiveTest, Subscription, MockObserver, Recorded

rx.js/rx.js.time.d.ts

@@ -3,11 +3,8 @@
 // Type definitions for RxJS "Aggregates"
 // Project: http://rx.codeplex.com/
 // Definitions by: Carl de Billy <http://carl.debilly.net/>
+// Revision by: Igor Oleinikov <https://github.com/Igorbek>
 // Definitions: https://github.com/borisyankov/DefinitelyTyped
-//
-// Dependencies:
-// -> rx.js
-// -> rx.time.js
 
 declare module Rx {
 

rx.js/rx.testing.d.ts

@@ -0,0 +1,53 @@
+///<reference path="rx.js.d.ts" />
+///<reference path="rx.js.virtualtime.d.ts" />
+
+// Type definitions for RxJS-Testing
+// Project: https://github.com/Reactive-Extensions/RxJS/
+// Definitions by: Igor Oleinikov <https://github.com/Igorbek>
+// Definitions: https://github.com/borisyankov/DefinitelyTyped
+
+declare module Rx {
+	export class TestScheduler extends VirtualTimeScheduler<number, number> {
+		constructor();
+
+		createColdObservable<T>(...records: Recorded[]): Observable<T>;
+		createHotObservable<T>(...records: Recorded[]): Observable<T>;
+		createObserver<T>(): MockObserver<T>;
+
+		startWithTiming<T>(create: () => Observable<T>, createdAt: number, subscribedAt: number, disposedAt: number): MockObserver<T>;
+		startWithDispose<T>(create: () => Observable<T>, disposedAt: number): MockObserver<T>;
+		startWithCreate<T>(create: () => Observable<T>): MockObserver<T>;
+	}
+
+	export class Recorded {
+		constructor(time: number, value: any, equalityComparer?: (x: any, y: any) => boolean);
+		equals(other: Recorded): boolean;
+		toString(): string;
+		time: number;
+		value: any;
+	}
+
+	export var ReactiveTest: {
+		created: number;
+		subscribed: number;
+		disposed: number;
+
+		onNext(ticks: number, value: any): Recorded;
+		onNext(ticks: number, predicate: (value: any) => boolean): Recorded;
+		onError(ticks: number, exception: any): Recorded;
+		onError(ticks: number, predicate: (exception: any) => boolean): Recorded;
+		onCompleted(ticks: number): Recorded;
+
+		subscribe(subscribeAt: number, unsubscribeAt?: number): Subscription;
+	};
+
+	export class Subscription {
+		constructor(subscribeAt: number, unsubscribeAt?: number);
+		equals(other: Subscription): boolean;
+	}
+
+	export class MockObserver<T> extends Observer<T> {
+		constructor(scheduler: IScheduler);
+		messages: Recorded[];
+	}
+}