Similarly to the way Retry is implemented with accompanying retryWhen(RetrySpec) operator, the Repeat functionality from reactor-addons project should be implemented in reactor-core and phased out from reactor-extras (module of reactor-addons). It can potentially reuse the primitives that already exist for the retry functionality.