diff --git a/packages/nx/spec/testing-utils.spec.ts b/packages/nx/spec/testing-utils.spec.ts new file mode 100644 index 0000000000..ab18dbfa2e --- /dev/null +++ b/packages/nx/spec/testing-utils.spec.ts @@ -0,0 +1,27 @@ +import {from} from 'rxjs/Observable/from' +import {readAll, readFirst} from '../src/testing-utils'; + +describe('TestingUtils', () => { + describe('readAll', () => { + it('should transform Observable to Promise>', async (done) => { + const obs = from([1, 2, 3]); + const result = await readAll(obs); + + expect(result).toEqual([1, 2, 3]); + + done(); + }); + }); + + describe('readFirst', () => { + it('should transform first item emitted from Observable to Promise', async (done) => { + const obs = from([1, 2, 3]); + const result = await readFirst(obs); + + expect(result).toBe(1); + + done(); + }); + }); +}); +