Chapter 24 : UseCase21 - Conflation Deep Dive
buffer() in Chapter 23 was all about “queue everything” when the consumer is slow. Now we look into conflate() which is all about “dropping intermediate values” and caring only about the latest value.
The Core Idea
When the consumer is slow:
buffer(...