reactor/reactor-core

New operator - delayBetween

Open

#3.582 geöffnet am 21. Sept. 2023

Auf GitHub ansehen
 (9 Kommentare) (5 Reaktionen) (0 zugewiesene Personen)Java (1.164 Forks)batch import
help wantedstatus/has-workaround

Repository-Metriken

Stars
 (4.748 Stars)
PR-Merge-Metriken
 (Durchschn. Merge 16T 15h) (25 gemergte PRs in 30 T)

Beschreibung

Summary:

Current Flux.delayElements will delay the elements since the start of the first elements. It would be nice to have another operator that will give delay between elements.

Example:

Flux.delayElements(Duration.ofHour(1)) 5 Elements arrived --> delay 1 hour --> element 1 processed --> delay 1 hour --> element 2 processed ...

Flux.delayBetween(Duration.ofHour(1)) 5 elements arrived --> element 1 processed --> delay 1 hour --> element 2 processed ...

Contributor Guide