Skip to content

Commit

Permalink
chore(zipWith): update tests for run mode
Browse files Browse the repository at this point in the history
  • Loading branch information
@benlesh
benlesh committed Jan 21, 2020
1 parent d701ea5 commit 651c946
Show file tree
Hide file tree
Showing 2 changed files with 577 additions and 445 deletions.
225 changes: 146 additions & 79 deletions spec/operators/zip-legacy-spec.ts
View file
Original file line number Diff line number Diff line change
@@ -1,106 +1,173 @@
import { expect } from 'chai';
import { hot, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
import { zip } from 'rxjs/operators';
import { from } from 'rxjs';
import { TestScheduler } from 'rxjs/testing';
import { observableMatcher } from '../helpers/observableMatcher';

/**
* zip legacy still supports a mapping function, but it's deprecated
*/
describe('zip legacy', () => {
/**
* zip legacy still supports a mapping function, but it's deprecated
*/
it('should zip the provided observables', (done) => {
let rxTestScheduler: TestScheduler;

beforeEach(() => {
rxTestScheduler = new TestScheduler(observableMatcher);
});

it('should zip the provided observables', done => {
const expected = ['a1', 'b2', 'c3'];
let i = 0;

from(['a', 'b', 'c']).pipe(zip(
from([1, 2, 3]),
(a, b): string => a + b
))
.subscribe(function (x) {
expect(x).to.equal(expected[i++]);
}, null, done);
from(['a', 'b', 'c'])
.pipe(zip(from([1, 2, 3]), (a, b): string => a + b))
.subscribe(
function(x) {
expect(x).to.equal(expected[i++]);
},
null,
done
);
});

it('should work with selector throws', () => {
rxTestScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const a = hot('---1-^-2---4----| ');
const asubs = ' ^-------! ';
const b = hot('---1-^--3----5----|');
const bsubs = ' ^-------! ';
const expected = ' ---x----# ';

const selector = function(x: string, y: string) {
if (y === '5') {
throw new Error('too bad');
} else {
return x + y;
}
};
const observable = a.pipe(zip(b, selector));
expectObservable(observable).toBe(expected, { x: '23' }, new Error('too bad'));
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
});
});

it('should work with some data asymmetric 1', () => {
const a = hot('---1-^-1-3-5-7-9-x-y-z-w-u-|');
const asubs = '^ ! ';
const b = hot('---1-^--2--4--6--8--0--| ');
const bsubs = '^ ! ';
const expected = '---a--b--c--d--e--| ';

expectObservable(a.pipe(zip(b, function (r1, r2) { return r1 + r2; })))
.toBe(expected, { a: '12', b: '34', c: '56', d: '78', e: '90' });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
rxTestScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const a = hot('---1-^-1-3-5-7-9-x-y-z-w-u-|');
const asubs = ' ^-----------------! ';
const b = hot('---1-^--2--4--6--8--0--| ');
const bsubs = ' ^-----------------! ';
const expected = ' ---a--b--c--d--e--| ';

expectObservable(
a.pipe(
zip(b, function(r1, r2) {
return r1 + r2;
})
)
).toBe(expected, { a: '12', b: '34', c: '56', d: '78', e: '90' });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
});
});

it('should work with some data asymmetric 2', () => {
const a = hot('---1-^--2--4--6--8--0--| ');
const asubs = '^ ! ';
const b = hot('---1-^-1-3-5-7-9-x-y-z-w-u-|');
const bsubs = '^ ! ';
const expected = '---a--b--c--d--e--| ';

expectObservable(a.pipe(zip(b, function (r1, r2) { return r1 + r2; })))
.toBe(expected, { a: '21', b: '43', c: '65', d: '87', e: '09' });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
rxTestScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const a = hot('---1-^--2--4--6--8--0--| ');
const asubs = ' ^-----------------! ';
const b = hot('---1-^-1-3-5-7-9-x-y-z-w-u-|');
const bsubs = ' ^-----------------! ';
const expected = ' ---a--b--c--d--e--| ';

expectObservable(
a.pipe(
zip(b, function(r1, r2) {
return r1 + r2;
})
)
).toBe(expected, { a: '21', b: '43', c: '65', d: '87', e: '09' });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
});
});

it('should work with some data symmetric', () => {
const a = hot('---1-^-1-3-5-7-9------| ');
const asubs = '^ ! ';
const b = hot('---1-^--2--4--6--8--0--|');
const bsubs = '^ ! ';
const expected = '---a--b--c--d--e-| ';

expectObservable(a.pipe(zip(b, function (r1, r2) { return r1 + r2; })))
.toBe(expected, { a: '12', b: '34', c: '56', d: '78', e: '90' });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
rxTestScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const a = hot('---1-^-1-3-5-7-9------| ');
const asubs = ' ^----------------! ';
const b = hot('---1-^--2--4--6--8--0--|');
const bsubs = ' ^----------------! ';
const expected = ' ---a--b--c--d--e-| ';

expectObservable(
a.pipe(
zip(b, function(r1, r2) {
return r1 + r2;
})
)
).toBe(expected, { a: '12', b: '34', c: '56', d: '78', e: '90' });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
});
});

it('should work with n-ary symmetric selector', () => {
const a = hot('---1-^-1----4----|');
const asubs = '^ ! ';
const b = hot('---1-^--2--5----| ');
const bsubs = '^ ! ';
const c = hot('---1-^---3---6-| ');
const expected = '----x---y-| ';

const observable = a.pipe(zip(b, c,
function (r0, r1, r2) { return [r0, r1, r2]; }));
expectObservable(observable).toBe(expected,
{ x: ['1', '2', '3'], y: ['4', '5', '6'] });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
rxTestScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const a = hot('---1-^-1----4----|');
const asubs = ' ^---------! ';
const b = hot('---1-^--2--5----| ');
const bsubs = ' ^---------! ';
const c = hot('---1-^---3---6-| ');
const expected = ' ----x---y-| ';

const observable = a.pipe(
zip(b, c, function(r0, r1, r2) {
return [r0, r1, r2];
})
);
expectObservable(observable).toBe(expected, { x: ['1', '2', '3'], y: ['4', '5', '6'] });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
});
});

it('should work with n-ary symmetric array selector', () => {
const a = hot('---1-^-1----4----|');
const asubs = '^ ! ';
const b = hot('---1-^--2--5----| ');
const bsubs = '^ ! ';
const c = hot('---1-^---3---6-| ');
const expected = '----x---y-| ';

const observable = a.pipe(zip(b, c,
function (r0, r1, r2) { return [r0, r1, r2]; }));
expectObservable(observable).toBe(expected,
{ x: ['1', '2', '3'], y: ['4', '5', '6'] });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
rxTestScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const a = hot('---1-^-1----4----|');
const asubs = ' ^---------! ';
const b = hot('---1-^--2--5----| ');
const bsubs = ' ^---------! ';
const c = hot('---1-^---3---6-| ');
const expected = ' ----x---y-| ';

const observable = a.pipe(
zip(b, c, function(r0, r1, r2) {
return [r0, r1, r2];
})
);
expectObservable(observable).toBe(expected, { x: ['1', '2', '3'], y: ['4', '5', '6'] });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
});
});

it('should combine two observables and selector', () => {
const a = hot('---1---2---3---');
const asubs = '^';
const b = hot('--4--5--6--7--8--');
const bsubs = '^';
const expected = '---x---y---z';

expectObservable(a.pipe(zip(b, function (e1, e2) { return e1 + e2; })))
.toBe(expected, { x: '14', y: '25', z: '36' });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
rxTestScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const a = hot(' ---1---2---3---');
const asubs = ' ^';
const b = hot(' --4--5--6--7--8--');
const bsubs = ' ^';
const expected = '---x---y---z';

expectObservable(
a.pipe(
zip(b, function(e1, e2) {
return e1 + e2;
})
)
).toBe(expected, { x: '14', y: '25', z: '36' });
expectSubscriptions(a.subscriptions).toBe(asubs);
expectSubscriptions(b.subscriptions).toBe(bsubs);
});
});
});
});
Loading

0 comments on commit 651c946

Please sign in to comment.