/** * @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 */ // #docregion Observable import {Observable, Subscriber} from 'rxjs/Rx'; var obs = new Observable((obs: Subscriber) => { var i = 0; setInterval(() => { obs.next(++i); }, 1000); }); obs.subscribe(i => console.log(`${i} seconds elapsed`)); // #enddocregion