Skip to main content
19 questions
Newest Active Bountied Unanswered
40 votes
3 answers
28k views

I'm trying to understand throttleTime vs debounceTime and which one is to be used when? I have an upvote button that makes an API request to the backend (which counts the votes). User can submit ...
Cleave Kokle's user avatar
  • 423
18 votes
5 answers
7k views

I have a component which triggers an onScrollEnd event when the last item in a virtual list is rendered. This event will do a new API request to fetch the next page and merge them with the previous ...
Ritchie's user avatar
  • 582
16 votes
1 answer
32k views

A very common problem when using RxJs seems to be to want the result of one or more observables to then use them in subsequent ones. e.g. in pseudo-code (This is not rx or valid js syntax ...
James's user avatar
  • 2,972
1 vote
2 answers
274 views

I have two observable data streams. One retrieves an account, one gets permissions. What I need to do is check if the current user has the role of admin, or has the role of external and the current ...
Dan Morphis's user avatar
  • 1,746
25 votes
1 answer
18k views

Having the following (just a quick example): observable.pipe(map( s => s.anything )) .pipe(filter(t => t > 5)) .pipe(map( t => t+5)) .subscribe( XXX ) Why ...
user2992476's user avatar
  • 1,686
4 votes
2 answers
3k views

I'm using RxJS shareReplay() operator on an observable (courses$) to share observable stream among other two observables (beginnerCourses$ and advancedCourses$). It's working fine and single API call ...
Gourav Pokharkar's user avatar
  • 1,648
4 votes
2 answers
2k views

Considering I have the following code: let Rx = window['rxjs']; const { of, queueScheduler, asapScheduler, asyncScheduler, animationFrameScheduler } = Rx; const { observeOn, tap } =...
anonymous's user avatar
  • 1,731
4 votes
3 answers
3k views

I have two observable streams which do very separate mapping logic, but then ultimately end with following 3 operators: this.selection .pipe( ..Custom mapping operators tap(_ => ...
MikeByte's user avatar
  • 173
4 votes
1 answer
5k views

I'm trying to use below simplified version of my http request pipeline to ensure that if my response does not have the required data in res.myCondition to utlize repeatWhen and make another call, but ...
Farnoosh's user avatar
  • 197
4 votes
1 answer
2k views

I was wondering if it's possible to create a type guard which checks if every item of an array is defined. I already have a type guard for checking a single value, but having a solution that would do ...
Dawid Zbiński's user avatar
  • 5,846
2 votes
1 answer
350 views

I am looking for an operator that would help me pace the results emitted from an observable, it would look like this : [--A-BC--D-E----------------] [--A----B----C----D----E----] I tried AuditTime() ...
leonsaysHi's user avatar
  • 375
2 votes
1 answer
2k views

I have an RxJS Observable that emits a series of changes to an underlying data structure—specifically, snapshotChanges() from an AngularFirestoreCollection. I'm currently mapping this to an array of ...
Alex Peters's user avatar
  • 2,986
1 vote
1 answer
307 views

I'm looking for a way to make streams that are combined Note: this is the simplest form of my problem, in reality I'm combining 8 different streams some are intertwined, some are async etc :( import { ...
Jason Rogers's user avatar
  • 19.4k
1 vote
1 answer
455 views

I am trying to swap two items in the observable array. I know how to do it in the normal array. I tried the same way but it doesn't change the value. My Stackblitz code Here is what I tried, ...
anonymous's user avatar
  • 1,731
0 votes
0 answers
67 views

I created a mini app which shows the Continent & the Country selections You can checkout to ng-conf/learn-rxjs-01 branch on https://stackblitz.com/edit/stackblitz-starters-hvcdxw to view the app ...
Angular animal's user avatar
  • 133

15 30 50 per page
1
2