reactor-core icon indicating copy to clipboard operation
reactor-core copied to clipboard

Add bufferWeightedWithin operator.

Open He-Pin opened this issue 1 year ago • 0 comments

Motivation:

Just as currently bufferTimeout but will emit when the weight exceeds, works as groupedWeightedWithin - Documentation - Akka Both in Akka/Pekko.

this can be used to implement bufferTimeout too.

and can act as a replacement of the current behavior of bufferTimeout.

refs: https://github.com/reactor/reactor-core/issues/2236

He-Pin avatar Mar 22 '24 02:03 He-Pin