reactor/reactor-core

New operator - delayBetween

Open

#3,582 创建于 2023年9月21日

在 GitHub 查看
 (9 评论) (5 反应) (0 负责人)Java (1,164 fork)batch import
help wantedstatus/has-workaround

仓库指标

Star
 (4,748 star)
PR 合并指标
 (平均合并 16天 15小时) (30 天内合并 25 个 PR)

描述

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

贡献者指南