TestScheduler.d.ts 1.5 KB

12345678910111213141516171819202122232425262728
  1. import { Observable } from '../Observable';
  2. import { ColdObservable } from './ColdObservable';
  3. import { HotObservable } from './HotObservable';
  4. import { TestMessage } from './TestMessage';
  5. import { SubscriptionLog } from './SubscriptionLog';
  6. import { VirtualTimeScheduler } from '../scheduler/VirtualTimeScheduler';
  7. export declare type observableToBeFn = (marbles: string, values?: any, errorValue?: any) => void;
  8. export declare type subscriptionLogsToBeFn = (marbles: string | string[]) => void;
  9. export declare class TestScheduler extends VirtualTimeScheduler {
  10. assertDeepEqual: (actual: any, expected: any) => boolean | void;
  11. private hotObservables;
  12. private coldObservables;
  13. private flushTests;
  14. constructor(assertDeepEqual: (actual: any, expected: any) => boolean | void);
  15. createTime(marbles: string): number;
  16. createColdObservable<T>(marbles: string, values?: any, error?: any): ColdObservable<T>;
  17. createHotObservable<T>(marbles: string, values?: any, error?: any): HotObservable<T>;
  18. private materializeInnerObservable(observable, outerFrame);
  19. expectObservable(observable: Observable<any>, unsubscriptionMarbles?: string): ({
  20. toBe: observableToBeFn;
  21. });
  22. expectSubscriptions(actualSubscriptionLogs: SubscriptionLog[]): ({
  23. toBe: subscriptionLogsToBeFn;
  24. });
  25. flush(): void;
  26. static parseMarblesAsSubscriptions(marbles: string): SubscriptionLog;
  27. static parseMarbles(marbles: string, values?: any, errorValue?: any, materializeInnerObservables?: boolean): TestMessage[];
  28. }