-
Notifications
You must be signed in to change notification settings - Fork 2
/
beforeError.spec.ts
27 lines (23 loc) · 1.13 KB
/
beforeError.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
27
import {marbles} from 'rxjs-marbles';
import {beforeError} from './beforeError';
describe('beforeError', () => {
it('should emit nothing for empty observables', marbles(m => {
m.expect(m.cold('').pipe(beforeError())).toBeObservable('');
m.expect(m.cold('|').pipe(beforeError())).toBeObservable('|');
}));
it('should emit nothing if no errors', marbles(m => {
m.expect(m.cold('a-b-c-d-e').pipe(beforeError())).toBeObservable('');
m.expect(m.cold('(abcde)').pipe(beforeError())).toBeObservable('');
m.expect(m.cold('a-b-c-d-e|').pipe(beforeError())).toBeObservable('---------|');
}));
it('should emit the previous value upon an error', marbles(m => {
const source = m.cold('a-b-c-d-#').pipe(beforeError());
const result = ' --------(a|)';
m.expect(source).toBeObservable(result, {a: ['d']});
}));
it('should emit the previous 3 values upon an error', marbles(m => {
const source = m.cold('a-b-c-d-#').pipe(beforeError(3));
const result = ' --------(a|)';
m.expect(source).toBeObservable(result, {a: ['d', 'c', 'b']});
}));
});