CODEWITHSUNDEEP
javascriptreactive-programmingfrprxjs
tldr
tldr

Reputation: 12112

Flatmap concurrency limit (like bacon.js)?

I'm looking at the RxJS docs for something like bacon's flatMapWithConcurrencyLimit, but don't see anything. Any idea if it's available in Rx or not?

Upvotes: 1

Views: 217

Answers (2)

Jose V
Jose V

Reputation: 1854

a simpler option without pulling an entire library of streams/observables: https://www.npmjs.com/package/queue

Upvotes: 0

Dave Sexton
Dave Sexton

Reputation: 2652

In Rx.NET there's a Merge operator that accepts a maximum concurrency parameter. Essentially, its semantics are the same as SelectMany (a.k.a., FlatMap) with a concurrency limit.

It seems that Rx.JS defines this overload as well: merge.

Upvotes: 2

Related Questions