Compare commits

...

2 Commits

Author SHA1 Message Date
3812a8a323 chore(deps): lock file maintenance
All checks were successful
Build / Build and analyze (pull_request) Successful in 1m41s
2024-10-01 07:01:18 +00:00
d1cc5b076d
feat(app): add observable stream processing in ngOnInit
All checks were successful
Build / Build and analyze (push) Successful in 1m43s
2024-10-01 08:27:41 +02:00
3 changed files with 3706 additions and 4516 deletions

8186
package-lock.json generated

File diff suppressed because it is too large Load Diff

@ -5,6 +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';
@Component({
selector: 'app-root',
@ -18,6 +19,27 @@ export class AppComponent {
public search: string = "";
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();
});
stream.pipe(
filter((value:number) => value % 2 === 1),
map((value:number) => value * 2)
).subscribe((value) => console.log(value));
}
public test() {
console.log(this.search);
}

@ -1,6 +1,10 @@
import { bootstrapApplication } from '@angular/platform-browser';
import { appConfig } from './app/app.config';
import { AppComponent } from './app/app.component';
import { Observable } from 'rxjs';
bootstrapApplication(AppComponent, appConfig)
.catch((err) => console.error(err));