Skip to content

Add bufferWeightedWithin operator. #3774

@He-Pin

Description

@He-Pin

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: #2236

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions