I am trying to make a slightly complex queue system in rxjs as follows: any user can request a title at any time as long as they have no request or timeout pending any user with a title can cancel…
How to perform operations on 2 separate data collections in 1 function in RxJS so that it returns observable -> as for now it returns Void ? This function is running inside Service of course, and finally I want to…
i am fetching the data form an API beck-end and displaying its content in to my view in angular, for the service i am using observables export class PropertyService { apiUrl: string = environment.domain; constructor(private http: HttpClient) {} private _propertyDetailedInfo…
How to return different values from the same observable without multiple calls? I intend to subscribe just one time the firstObs$, but return the values and sumFromValues. combineLatest([ this.firstObs$, this.firstObs$.pipe( switchMap(someOperation => { return this.observableSumOperation(someOperation.first, someOperation.second) }) ), this.anotherObservable$, ])…
I have a piece of code that looks like this getInformations().subscribe( informations => { let subs = []; for (const information of informations) { subs.push(getOtherDetails(information.id)); } forkJoin(subs).subscribe(response => { //How can I Associate Information Id With The Response howToAssociateIdWithResponse(); }}…
I have two services which returns Observables one is admin service which checks if user is admin and the second one is the service with method fetching CVs to see if user has already created cv. I want to lock…
I have the following piece of code: readonly todos$: Observable<Todo[]> = combineLatest([this.account$, this.loadTodoPage$]).pipe( concatMap(([account, pageNo]) => this.todoService.getTodos(account.id, pageNo)), scan((acc: Todo[], curr: Todo[]) => [...acc, ...curr], []) ); This always loads a new page of todos from the backend when i…
I am trying to make a simple TODO app in angular using RXJS. I have a JSON server mock database with my TODO tasks. So I ended up with this TasksService: @Injectable({ providedIn: 'root' }) export class TasksService { private…
I want to make multiple parallel API calls using the same endpoint but different parameters. And subscribe to it if any of the request is complete. How can I handle this. This is my current approach. I am unsure of…
I am using an observable to retrieve data from an http like: handleError(error:any) { ... } getData() { return this._api_service.http.get<JSON>(this._url).pipe(retry(1), catchError(this.handleError)); } loadData() { this.getData().subscribe((data: {}) => { do_something_to_data(data); }); // here I want to do somethings after all the…