reactor/reactor-core

New operator - delayBetween

Open

#3,582 opened on 2023年9月21日

GitHub で見る
 (9 comments) (5 reactions) (0 assignees)Java (1,164 forks)batch import
help wantedstatus/has-workaround

Repository metrics

Stars
 (4,748 stars)
PR merge metrics
 (平均マージ 16d 15h) (30d で 25 merged PRs)

説明

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 ...

コントリビューターガイド