Skip to content

Commit

Permalink
chore: update materialize tests to run mode (#6038)
Browse files Browse the repository at this point in the history
  • Loading branch information
@jakovljevic-mladen
jakovljevic-mladen authored Feb 22, 2021
1 parent 6f7cee5 commit 7208ea7
Showing 1 changed file with 129 additions and 111 deletions.
240 changes: 129 additions & 111 deletions spec/operators/materialize-spec.ts
View file
Original file line number Diff line number Diff line change
@@ -1,145 +1,164 @@
/** @prettier */
import { expect } from 'chai';
import { materialize, map, mergeMap, take } from 'rxjs/operators';
import { Notification, of, Observable } from 'rxjs';
import { hot, cold, expectObservable, expectSubscriptions } from '../helpers/marble-testing';
import { TestScheduler } from 'rxjs/testing';
import { observableMatcher } from '../helpers/observableMatcher';

/** @test {materialize} */
describe('materialize operator', () => {
describe('materialize', () => {
let testScheduler: TestScheduler;

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

it('should materialize an Observable', () => {
const e1 = hot('--x--y--z--|');
const expected = '--a--b--c--(d|)';
const values = { a: '{x}', b: '{y}', c: '{z}', d: '|' };

const result = e1.pipe(
materialize(),
map((x: Notification<any>) => {
if (x.kind === 'C') {
return '|';
} else {
return '{' + x.value + '}';
}
})
);

expectObservable(result).toBe(expected, values);
testScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const e1 = hot(' --x--y--z--| ');
const e1subs = ' ^----------! ';
const expected = '--a--b--c--(d|)';
const values = { a: '{x}', b: '{y}', c: '{z}', d: '|' };

const result = e1.pipe(
materialize(),
map((x: Notification<string>) => {
if (x.kind === 'C') {
return '|';
} else {
return '{' + x.value + '}';
}
})
);

expectObservable(result).toBe(expected, values);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
});
});

it('should materialize a happy stream', () => {
const e1 = hot('--a--b--c--|');
const e1subs = '^ !';
const expected = '--w--x--y--(z|)';

const expectedValue = {
w: Notification.createNext('a'),
x: Notification.createNext('b'),
y: Notification.createNext('c'),
z: Notification.createComplete()
};

expectObservable(e1.pipe(materialize())).toBe(expected, expectedValue);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
testScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const e1 = hot(' --a--b--c--| ');
const e1subs = ' ^----------! ';
const expected = '--w--x--y--(z|)';

const expectedValue = {
w: Notification.createNext('a'),
x: Notification.createNext('b'),
y: Notification.createNext('c'),
z: Notification.createComplete(),
};

expectObservable(e1.pipe(materialize())).toBe(expected, expectedValue);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
});
});

it('should materialize a sad stream', () => {
const e1 = hot('--a--b--c--#');
const e1subs = '^ !';
const expected = '--w--x--y--(z|)';

const expectedValue = {
w: Notification.createNext('a'),
x: Notification.createNext('b'),
y: Notification.createNext('c'),
z: Notification.createError('error')
};

expectObservable(e1.pipe(materialize())).toBe(expected, expectedValue);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
testScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const e1 = hot(' --a--b--c--# ');
const e1subs = ' ^----------! ';
const expected = '--w--x--y--(z|)';

const expectedValue = {
w: Notification.createNext('a'),
x: Notification.createNext('b'),
y: Notification.createNext('c'),
z: Notification.createError('error'),
};

expectObservable(e1.pipe(materialize())).toBe(expected, expectedValue);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
});
});

it('should allow unsubscribing explicitly and early', () => {
const e1 = hot('--a--b--c--|');
const unsub = ' ! ';
const e1subs = '^ ! ';
const expected = '--w--x- ';

const expectedValue = {
w: Notification.createNext('a'),
x: Notification.createNext('b')
};

expectObservable(e1.pipe(materialize()), unsub).toBe(expected, expectedValue);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
testScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const e1 = hot(' --a--b--c--|');
const e1subs = ' ^-----! ';
const expected = '--w--x- ';
const unsub = ' ------! ';

const expectedValue = {
w: Notification.createNext('a'),
x: Notification.createNext('b'),
};

expectObservable(e1.pipe(materialize()), unsub).toBe(expected, expectedValue);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
});
});

it('should not break unsubscription chains when result is unsubscribed explicitly', () => {
const e1 = hot('--a--b--c--|');
const e1subs = '^ ! ';
const expected = '--w--x- ';
const unsub = ' ! ';

const expectedValue = {
w: Notification.createNext('a'),
x: Notification.createNext('b')
};

const result = e1.pipe(
mergeMap((x: string) => of(x)),
materialize(),
mergeMap((x: Notification<any>) => of(x))
);

expectObservable(result, unsub).toBe(expected, expectedValue);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
});

it('should materialize stream does not completes', () => {
const e1 = hot('-');
const e1subs = '^';
const expected = '-';

expectObservable(e1.pipe(materialize())).toBe(expected);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
testScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const e1 = hot(' --a--b--c--|');
const e1subs = ' ^-----! ';
const expected = '--w--x- ';
const unsub = ' ------! ';

const expectedValue = {
w: Notification.createNext('a'),
x: Notification.createNext('b'),
};

const result = e1.pipe(
mergeMap((x: string) => of(x)),
materialize(),
mergeMap((x: Notification<string>) => of(x))
);

expectObservable(result, unsub).toBe(expected, expectedValue);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
});
});

it('should materialize stream never completes', () => {
const e1 = cold('-');
const e1subs = '^';
const expected = '-';
it('should materialize stream that does not complete', () => {
testScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const e1 = hot(' -');
const e1subs = ' ^';
const expected = '-';

expectObservable(e1.pipe(materialize())).toBe(expected);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
expectObservable(e1.pipe(materialize())).toBe(expected);
expectSubscriptions(e1.subscriptions).toBe(e1subs);
});
});

it('should materialize stream does not emit', () => {
const e1 = hot('----|');
const e1subs = '^ !';
const expected = '----(x|)';
it('should materialize stream that does not emit', () => {
testScheduler.run(({ hot, expectObservable, expectSubscriptions }) => {
const e1 = hot(' ----| ');
const e1subs = ' ^---! ';
const expected = '----(x|)';

expectObservable(e1.pipe(materialize())).toBe(expected, { x: Notification.createComplete() });
expectSubscriptions(e1.subscriptions).toBe(e1subs);
expectObservable(e1.pipe(materialize())).toBe(expected, { x: Notification.createComplete() });
expectSubscriptions(e1.subscriptions).toBe(e1subs);
});
});

it('should materialize empty stream', () => {
const e1 = cold('|');
const e1subs = '(^!)';
const expected = '(x|)';
testScheduler.run(({ cold, expectObservable, expectSubscriptions }) => {
const e1 = cold(' | ');
const e1subs = ' (^!)';
const expected = '(x|)';

expectObservable(e1.pipe(materialize())).toBe(expected, { x: Notification.createComplete() });
expectSubscriptions(e1.subscriptions).toBe(e1subs);
expectObservable(e1.pipe(materialize())).toBe(expected, { x: Notification.createComplete() });
expectSubscriptions(e1.subscriptions).toBe(e1subs);
});
});

it('should materialize stream throws', () => {
const e1 = cold('#');
const e1subs = '(^!)';
const expected = '(x|)';
it('should materialize stream that throws', () => {
testScheduler.run(({ cold, expectObservable, expectSubscriptions }) => {
const e1 = cold(' # ');
const e1subs = ' (^!)';
const expected = '(x|)';

expectObservable(e1.pipe(materialize())).toBe(expected, { x: Notification.createError('error') });
expectSubscriptions(e1.subscriptions).toBe(e1subs);
expectObservable(e1.pipe(materialize())).toBe(expected, { x: Notification.createError('error') });
expectSubscriptions(e1.subscriptions).toBe(e1subs);
});
});

it('should stop listening to a synchronous observable when unsubscribed', () => {
const sideEffects: number[] = [];
const synchronousObservable = new Observable<number>(subscriber => {
const synchronousObservable = new Observable<number>((subscriber) => {
// This will check to see if the subscriber was closed on each loop
// when the unsubscribe hits (from the `take`), it should be closed
for (let i = 0; !subscriber.closed && i < 10; i++) {
Expand All @@ -148,10 +167,9 @@ describe('materialize operator', () => {
}
});

synchronousObservable.pipe(
materialize(),
take(3),
).subscribe(() => { /* noop */ });
synchronousObservable.pipe(materialize(), take(3)).subscribe(() => {
/* noop */
});

expect(sideEffects).to.deep.equal([0, 1, 2]);
});
Expand Down

0 comments on commit 7208ea7

Please sign in to comment.