mirror of
https://github.com/zhigang1992/DefinitelyTyped.git
synced 2026-04-23 21:00:01 +08:00
a5a69f514a
* Move rx.virtualtime to its own package * Update headers * Update module name * Move rx.time to its own package * Update header and module name * Move rx.testing to its own package * Update headers and module name * Move rx.joinpatterns to its own package * Update headers and module name * Move rx.expermental to its own package * Update headder and module name * Move rx.coincidence to its own package * Combine rx.coincidence-lite.d.ts and rx.coincidence.d.ts into one file * Update header and module name * Move rx.binding to its own package * combine rx.binding into index.d.ts * Update headers and module name * Move rx.backpressure to its own package * Fix headers and update module name * Move rx.aggregte to its own package * Fix headers and update module name * move rx.async to its own package * Fix headers and module name * move startAsync to rx-lite-async * Move fromCallback tests back to rx * Move rx-lite to its own package * Fix headers * Combine files * import new module * Fix file extension * Fix strict null checks * Move definitions back to rx * move rx-core to its own package * Update header and change module name * Fix lint errors * reference new rx-core * update index.d.ts * Point to new submodules * turn strictNull On * update tslint config * Update module name * Move Subject to core-binding * Make rx-lite-* libraries depend on rx-lite * Fix reference * Fix lint errors * Disable lint rules * Disable lint rules * Fix failing test * Fixed up indentation on 'rx-lite-async-tests.ts' * Fix formatting * Switch tabs to spaces
62 lines
2.0 KiB
TypeScript
62 lines
2.0 KiB
TypeScript
// Type definitions for rx-lite-testing 4.0
|
|
// Project: https://github.com/Reactive-Extensions/RxJS
|
|
// Definitions by: Igor Oleinikov <https://github.com/Igorbek>
|
|
// Definitions: https://github.com/DefinitelyTyped/DefinitelyTyped
|
|
|
|
/// <reference types="rx-lite-virtualtime" />
|
|
|
|
declare namespace Rx {
|
|
export interface TestScheduler extends VirtualTimeScheduler<number, number> {
|
|
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 var TestScheduler: {
|
|
new (): TestScheduler;
|
|
};
|
|
|
|
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;
|
|
onError(ticks: number, exception: any): Recorded;
|
|
onCompleted(ticks: number): Recorded;
|
|
|
|
subscribe(subscribeAt: number, unsubscribeAt?: number): Subscription;
|
|
};
|
|
|
|
export class Subscription {
|
|
constructor(subscribeAt: number, unsubscribeAt?: number);
|
|
equals(other: Subscription): boolean;
|
|
}
|
|
|
|
export interface MockObserver<T> extends Observer<T> {
|
|
messages: Recorded[];
|
|
}
|
|
|
|
interface MockObserverStatic extends ObserverStatic {
|
|
new <T>(scheduler: IScheduler): MockObserver<T>;
|
|
}
|
|
|
|
export var MockObserver: MockObserverStatic;
|
|
}
|
|
|
|
declare module "rx-lite-testing" {
|
|
export = Rx;
|
|
}
|