Explore timed microbatch operators

spring-attic / reactive-streams-commons

A joint research effort for building highly optimized Reactive-Streams compliant operators.

Apache License 2.0

357 stars 51 forks source link

Explore timed microbatch operators #15

Open smaldini opened 8 years ago

smaldini commented 8 years ago

Currently written with a combination of 2 or 3 operators, timed microbatch like stream.window(10, () -> PublisherBase.timer(....)) or stream.buffer(10, () -> PublisherBase.timer(....)) would be useful.