Mein Anwendungsfall ist wie folgt: Ich erhalte Ereignisse, die manchmal in Bursts auftreten. Wenn ein Burst auftritt, muss ich ihn nur einmal behandeln. Debounce macht das.

Debounce gibt mir jedoch nur das letzte Element eines Bursts, aber ich muss alle Elemente in einem Burst kennen, um sie zu aggregieren (mit flatmap).

Dies könnte durch ein zeitgesteuertes Fenster oder einen zeitgesteuerten Puffer erfolgen. Dies sind jedoch feste Intervalle, sodass ein Puffer- / Fenster-Timeout in der Mitte eines Bursts auftreten kan

Also, was ich möchte, ist so etwas wie

.
.
event: a
.
. -> a
.
.
.
.
.
.event: b
.event: c
.event: d
.
.-> b,c,d
. 
.
.
.
.event : e
.
. -> e
.