ngOnInit() { // produces a number every one second const numbers$ = Observable.interval(1000); numbers$.pipe( take(5), map(x => x* 10) ).subscribe(x => console.log(x); ) }