reactor/reactor-core

New operator - delayBetween

Open

#3.582 aberto em 21 de set. de 2023

Ver no GitHub
 (9 comments) (5 reactions) (0 assignees)Java (1.164 forks)batch import
help wantedstatus/has-workaround

Métricas do repositório

Stars
 (4.748 stars)
Métricas de merge de PR
 (Mesclagem média 16d 15h) (25 fundiu PRs em 30d)

Description

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

Guia do colaborador