/** * @license * Copyright Google Inc. All Rights Reserved. * * Use of this source code is governed by an MIT-style license that can be * found in the LICENSE file at https://angular.io/license */ import {Observable, of } from 'rxjs'; import {timeout} from 'rxjs/operators'; import {asyncTest, isPhantomJS} from '../test-util'; describe('Observable.timeout', () => { let log: any[]; let observable1: Observable; beforeEach(() => { log = []; }); it('timeout func callback should run in the correct zone', asyncTest((done: any) => { if (isPhantomJS()) { done(); return; } const constructorZone1: Zone = Zone.current.fork({name: 'Constructor Zone1'}); const subscriptionZone: Zone = Zone.current.fork({name: 'Subscription Zone'}); observable1 = constructorZone1.run(() => { return of (1).pipe(timeout(10)); }); subscriptionZone.run(() => { observable1.subscribe( (result: any) => { log.push(result); expect(Zone.current.name).toEqual(subscriptionZone.name); }, (err: any) => { fail('should not call error'); }, () => { log.push('completed'); expect(Zone.current.name).toEqual(subscriptionZone.name); expect(log).toEqual([1, 'completed']); done(); }); }); }, Zone.root)); it('promise should run in the correct zone', asyncTest((done: any) => { const constructorZone1: Zone = Zone.current.fork({name: 'Constructor Zone1'}); const subscriptionZone: Zone = Zone.current.fork({name: 'Subscription Zone'}); const promise: any = constructorZone1.run(() => { return of (1).toPromise(); }); subscriptionZone.run(() => { promise.then( (result: any) => { expect(Zone.current.name).toEqual(subscriptionZone.name); expect(result).toEqual(1); done(); }, (err: any) => { fail('should not call error'); }); }); }, Zone.root)); });