rxjs - how do I debounceTime for multiple incoming events target multiple different objects dependent of an internal identifier

Question

regarding to the following topic: https://stackoverflow.com/a/39960980/4457758

how can I adjust this flow for multiple incoming events which are depending lets say on a given object id ... So I am getting a bunch of events with different object ids and I want to debounce them for every target object Id every xxx milli seconds? So I need for every object id a separate debouncer responsible only for one object id?

I think you can use debounce for this: src$.pipe(debounce(({ id }) => timer(getTimeForId(id)))) — Andrei Gătej
– Andrei Gătej, Commented Mar 29, 2020 at 17:06

frido · Accepted Answer · 2020-03-29 19:47:46Z

3

You can use groupBy to group incoming events by some parameter. Then debounce each group separately.

import { timer } from 'rxjs';
import { debounce, mergeMap, groupBy } from 'rxjs/operators';

eventStream$.pipe(
  groupBy(event => event.id),
  mergeMap(group$ => group$.pipe(
    debounce(event => timer(idToMillis(event.id)))
  ))
)

edited Mar 29, 2020 at 19:47

answered Mar 29, 2020 at 17:47

frido

14.3k5 gold badges46 silver badges59 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

ArgV Over a year ago

Thanks :) groupBy was the operator I was looking for :)

Collectives™ on Stack Overflow

rxjs - how do I debounceTime for multiple incoming events target multiple different objects dependent of an internal identifier

1 Answer 1

1 Comment

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Linked

Related