feat: Adds cachedFlatMap operator

[mdboon]

No description provided.

[changeset-bot]

🦋 Changeset detected

Latest commit: 0136323

The changes in this PR will be included in the next version bump.

This PR includes changesets to release 1 package

Name	Type
windpipe	Minor

Not sure what this means? Click here to learn what changesets are.

Click here if you're a maintainer who wants to add another changeset to this PR

[giraugh]

Would this work as a special case of like a .flatReduce() or something like that? Could then build a helper for working with a cache on top of that?

someStream
   .flatReduce($.cacheReducer(
     new Map(),
     atom => /* snip: determine key */,
     atom => /* snip: determine value */,
   ))

Would also leave the door open to other reductions like summing

someStream
  .flatReduce($.sumReducer(atom => produceAsyncNumber(atom)))

Or a manual setup

someStream
  .flatReduce((acc, atom) => doAsyncStuff(acc, atom)) // should return a stream that emits once w/ next acc val

[andogq]

Would this work as a special case of like a .flatReduce() or something like that? Could then build a helper for working with a cache on top of that?

someStream
   .flatReduce($.cacheReducer(
     new Map(),
     atom => /* snip: determine key */,
     atom => /* snip: determine value */,
   ))

I think it's worthwhile having a publicly exposed cachedFlatMap (as Mark's done here), but it would be good if it were implemented in terms of flatReduce under the hood. I don't think we should worry about it for now, given that flatReduce doesn't exist atm.

(also mark is getting antsy, please help)

[giraugh]

Sounds good to me 👍
Roger roger, sending more ants 🐜 🐜 🐜 🐜