From 382e5263bfb95044e12d804588ce08e140ca2aec Mon Sep 17 00:00:00 2001 From: Jan Klattenhoff Date: Tue, 1 Oct 2024 09:36:52 +0200 Subject: [PATCH] refactor(app.component): simplify observable stream creation --- src/app/app.component.ts | 25 +++++++++---------------- 1 file changed, 9 insertions(+), 16 deletions(-) diff --git a/src/app/app.component.ts b/src/app/app.component.ts index 6c1f47b..dcd8668 100644 --- a/src/app/app.component.ts +++ b/src/app/app.component.ts @@ -5,7 +5,7 @@ import { UpperCasePipe } from '@angular/common'; import { TextPipe } from '../text.pipe'; import { HotelService } from './Parent/services/hotel.service'; import { inject } from '@angular/core'; -import { filter, map, Observable } from 'rxjs'; +import { filter, map, Observable, range } from 'rxjs'; @Component({ selector: 'app-root', @@ -20,27 +20,20 @@ export class AppComponent { public hotelService: HotelService = inject(HotelService); ngOnInit() { - const stream: Observable = new Observable((observer) => { - observer.next(1); - observer.next(2); - observer.next(3); - observer.next(4); - observer.next(5); - observer.next(6); - observer.next(7); - observer.next(8); - observer.next(9); - observer.next(10); - observer.complete(); - }); + const stream: Observable = range(1, 10); stream.pipe( - filter((value:number) => value % 2 === 1), - map((value:number) => value * 2) + filter((value: number) => value % 2 === 1), + ).subscribe((value) => console.log(value)); + console.log('---') + + stream.pipe( + map((value: number) => value * 2) ).subscribe((value) => console.log(value)); } public test() { + 8 console.log(this.search); }