import { Observable } from '../Observable'; import { ColdObservable } from './ColdObservable'; import { HotObservable } from './HotObservable'; import { TestMessage } from './TestMessage'; import { SubscriptionLog } from './SubscriptionLog'; import { VirtualTimeScheduler } from '../scheduler/VirtualTimeScheduler'; export interface RunHelpers { cold: typeof TestScheduler.prototype.createColdObservable; hot: typeof TestScheduler.prototype.createHotObservable; flush: typeof TestScheduler.prototype.flush; expectObservable: typeof TestScheduler.prototype.expectObservable; expectSubscriptions: typeof TestScheduler.prototype.expectSubscriptions; } export declare type observableToBeFn = (marbles: string, values?: any, errorValue?: any) => void; export declare type subscriptionLogsToBeFn = (marbles: string | string[]) => void; export declare class TestScheduler extends VirtualTimeScheduler { assertDeepEqual: (actual: any, expected: any) => boolean | void; readonly hotObservables: HotObservable[]; readonly coldObservables: ColdObservable[]; private flushTests; private runMode; constructor(assertDeepEqual: (actual: any, expected: any) => boolean | void); createTime(marbles: string): number; createColdObservable(marbles: string, values?: any, error?: any): ColdObservable; createHotObservable(marbles: string, values?: any, error?: any): HotObservable; private materializeInnerObservable(observable, outerFrame); expectObservable(observable: Observable, unsubscriptionMarbles?: string): ({ toBe: observableToBeFn; }); expectSubscriptions(actualSubscriptionLogs: SubscriptionLog[]): ({ toBe: subscriptionLogsToBeFn; }); flush(): void; /** @nocollapse */ static parseMarblesAsSubscriptions(marbles: string, runMode?: boolean): SubscriptionLog; /** @nocollapse */ static parseMarbles(marbles: string, values?: any, errorValue?: any, materializeInnerObservables?: boolean, runMode?: boolean): TestMessage[]; run(callback: (helpers: RunHelpers) => T): T; }