diff options
Diffstat (limited to 'sources/hv-collector-utils/src/main/kotlin/org/onap')
| -rw-r--r-- | sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/rx/rx.kt | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/rx/rx.kt b/sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/rx/rx.kt index e1886055..d68ca5c1 100644 --- a/sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/rx/rx.kt +++ b/sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/rx/rx.kt @@ -34,6 +34,6 @@ import java.time.Duration fun <T> Publisher<T>.then(callback: () -> Unit): Mono<Unit> = toMono().then(Mono.fromCallable(callback)) -fun <T> delayElements(intervalSupplier: () -> Duration): (Flux<T>) -> Flux<T> = { flux -> - flux.concatMap { Mono.just(it).delayElement(intervalSupplier()) } -} +fun <T> Flux<T>.nextWithVariableInterval(intervalSupplier: () -> Duration): Flux<T> = + concatMap { Mono.just(it).delayElement(intervalSupplier()) } + |