11 lines
		
	
	
		
			282 B
		
	
	
	
		
			TypeScript
		
	
	
	
	
	
		
		
			
		
	
	
			11 lines
		
	
	
		
			282 B
		
	
	
	
		
			TypeScript
		
	
	
	
	
	
| 
								 | 
							
								// #docregion Observable
							 | 
						||
| 
								 | 
							
								import {Observable} from 'angular2/core';
							 | 
						||
| 
								 | 
							
								import 'rxjs/add/operator/map';
							 | 
						||
| 
								 | 
							
								
							 | 
						||
| 
								 | 
							
								var obs = new Observable(obs => {
							 | 
						||
| 
								 | 
							
								  var i = 0;
							 | 
						||
| 
								 | 
							
								  setInterval(_ => obs.next(++i), 1000);
							 | 
						||
| 
								 | 
							
								});
							 | 
						||
| 
								 | 
							
								obs.map(i => `${i} seconds elapsed`).subscribe(msg => console.log(msg));
							 | 
						||
| 
								 | 
							
								// #enddocregion
							 |