Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 | 2x 2x 1x 1x 2x 2x | import { Observable } from 'rxjs';
/**
* @returns an Observable that proxies subscriptions to observables provided as arguments.
* Arguments are subscribed to in order they are provided.
*/
export const createStubObservable = <T>(...calls: Observable<T>[]) => {
let numCall = 0;
return new Observable<T>((subscriber) => {
const sub = calls[numCall++].subscribe(subscriber);
return () => sub.unsubscribe();
});
};
|