Mein Anwendungsfall ist wie folgt: Ich bekomme Ereignisse, die manchmal in Bursts passieren. Wenn ein Burst auftritt, muss ich nur einmal damit umgehen. Debounce macht das.
Aber Entprellen gibt mir nur das letzte Element eines Bursts, aber ich muss über alle Elemente in einem Burst Bescheid wissen, um auf ihnen zu aggregieren (mit Flatmap).
Dies könnte durch ein zeitgesteuertes Fenster oder einen Puffer erfolgen, dies sind jedoch feste Intervalle, so dass ein Puffer- / Fenster-Timeout in der Mitte eines Bursts auftreten könnte, wodurch der Burst in zwei Teile zerlegt wird, statt 1. / p>
Also was ich möchte, ist etwas wie
%Vor% Sie suchen wahrscheinlich nach bufferWithTimeOrCount
von der Seite:
%Vor%