refactor(app.component): simplify observable stream creation
All checks were successful
Build / Build and analyze (push) Successful in 1m41s
All checks were successful
Build / Build and analyze (push) Successful in 1m41s
This commit is contained in:
parent
d1cc5b076d
commit
382e5263bf
@ -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<number> = 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<number> = range(1, 10);
|
||||
|
||||
stream.pipe(
|
||||
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);
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user