-
Notifications
You must be signed in to change notification settings - Fork 414
/
mergeall-spec.ts
26 lines (25 loc) · 1.01 KB
/
mergeall-spec.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
declare var describe, it, expect, hot, cold, expectObservable, expectSubscriptions, rxTestScheduler, beforeEach;
import {Observable} from 'rxjs/Observable';
import 'rxjs/add/observable/of';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/mergeall';
describe('The concat operator examples', () => {
describe('Example 1 - mergeAll with promises', () => {
it('should emit the result of promises', (done) => {
const results = [];
const myPromise = val => new Promise(resolve => resolve(`Result: ${val}`))
const source = Observable.of(1,2,3);
const example = source
.map(val => myPromise(val))
.mergeAll();
const expected = ['Result: 1', 'Result: 2', 'Result: 3'];
example.subscribe({
next: val => results.push(val),
complete: () => {
expect(results).toDeepEqual(expected);
done();
}
});
});
});
});