In RxJS, how can I achieve this: I have two subjects. I want an observables that combines them in this way: When both have emitted values, emit the latest of their values. Then, both need to emit at least once…
Just need some clarification on documentation of takeUntilDestroyed operator, so reading this doc: https://angular.io/api/core/rxjs-interop/takeUntilDestroyed , I dont see any words that I should use takeUntilDestroyed without params only in "injection" context (I dont really know what does this means). So…
I have the method getAllDates that appends (inside the next handler) all the schedule dates from the server to class scope array variable this.futureScheduleDateStrings. My question is - should I initialize that array to empty content before subscribe method or…
import { of, mergeMap, concatAll, toArray, take } from 'rxjs' const duplicateValue = log => value => { console.log(log, value) return Promise.resolve([value, value]); } of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10).pipe( mergeMap(duplicateValue('mapping a'), 1), concatAll(), mergeMap(duplicateValue('mapping b'),…
I have an observable. I'm attempting to convert it to a promise using the lastValueFrom method. const obs = timer(1000).pipe( map(() => `First Value!`), startWith('But StartWith this') ); lastValueFrom(obs).then(console.log); Outputs: First Value! This is not what I was expecting because…
I have the following class: class BucketManager { private readonly bucketNames$ = new BehaviorSubject<string[] | null>(null) bucketNames = this.bucketNames$.asObservable().pipe(filter(bucketNames => !!bucketNames)) as Observable<string[]> constructor() { this.init() } async init() { const fetchedBuckets = await someExpensiveLongCalculation() this.bucketNames$.next(fetchedBuckets) } } Currently, the…
found this piece of code which is actually working but eslint is complaining about the misused promise this.subject$.pipe(delay(this.debounceTime || 0)).subscribe(async ({ entry, observer }) => { const target = entry.target as HTMLElement; const isStillVisible = await this.isVisible(target); isStillVisible ? this.visible.emit()…
Problem How to not subscribe if values are equal to the last emission this.first$.next('one'); this.second$.next(false); combine$ = combineLatest([this.first$, this.second$]) .pipe(map(([first, second]) => { //do something if one of the values is different })) Only subscribe if one of the values…
I do have big array of objects as response which contains more than 10k records, in each object in specific key value contains array, that should iterate and compare with another array of objects and if it matches, i want…
enable.service.ts @Injectable({ providedIn: 'root' }) export class EnableService { isEnabled$ = from(this.client.init()).pipe( switchMap(() => this.client.getEnabled()), map(([enabled, isAdmin]) => ({enabled: true, isAdmin: false})), share() ); // not exactly like this but some kind of observable that will return enable and isAdmin…