reactor-core
reactor-core copied to clipboard
Add bufferWeightedWithin operator.
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