| 1 | import { Observable } from 'rxjs';
|
| 2 | import { getTestScheduler } from './scheduler';
|
| 3 | export class TestColdObservable extends Observable {
|
| 4 | constructor(marbles, values, error) {
|
| 5 | super();
|
| 6 | this.marbles = marbles;
|
| 7 | this.values = values;
|
| 8 | this.error = error;
|
| 9 | const scheduler = getTestScheduler();
|
| 10 | const cold = scheduler.createColdObservable(marbles, values, error);
|
| 11 | this.source = cold;
|
| 12 | }
|
| 13 | getSubscriptions() {
|
| 14 | return this.source['subscriptions'];
|
| 15 | }
|
| 16 | }
|
| 17 | export class TestHotObservable extends Observable {
|
| 18 | constructor(marbles, values, error) {
|
| 19 | super();
|
| 20 | this.marbles = marbles;
|
| 21 | this.values = values;
|
| 22 | this.error = error;
|
| 23 | const scheduler = getTestScheduler();
|
| 24 | const hot = scheduler.createHotObservable(marbles, values, error);
|
| 25 | this.source = hot;
|
| 26 | }
|
| 27 | getSubscriptions() {
|
| 28 | return this.source['subscriptions'];
|
| 29 | }
|
| 30 | }
|
| 31 | |
| \ | No newline at end of file |