angular-cn/modules/angular2/examples/facade/ts/async/observable.ts

// #docregion Observable
import {Observable} from 'rxjs/Observable';
var obs = new Observable<number>(obs => {
  var i = 0;
  setInterval(_ => { obs.next(++i); }, 1000);
});
obs.subscribe(i => console.log(`${i} seconds elapsed`));
// #enddocregion
docs(Observable): add documentation for Observable and operators Closes #5642 Closes #5684 2015-12-07 16:38:12 -08:00			`// #docregion Observable`
feat(facade): do not reexport Observable from angular2/core BREAKING CHANGE Before import {Observable} from 'angular2/core' After import {Observable} from 'rxjs/Observable'; 2015-12-12 08:29:02 -08:00			`import {Observable} from 'rxjs/Observable';`
docs(Observable): add documentation for Observable and operators Closes #5642 Closes #5684 2015-12-07 16:38:12 -08:00			`var obs = new Observable<number>(obs => {`
			`var i = 0;`
			`setInterval(_ => { obs.next(++i); }, 1000);`
			`});`
			obs.subscribe(i => console.log(`${i} seconds elapsed`));
			`// #enddocregion`