diff options
| author |   kjaniak <kornel.janiak@nokia.com> | 2019-05-22 22:19:49 +0200 |
|---|---|---|
| committer | kjaniak <kornel.janiak@nokia.com> | 2019-06-05 16:01:22 +0200 |
| commit | 1ddd723f22c64dfb8c414fc8573ebe993ed00578 (patch) | |
| tree | 278aa739a0642cb40c358ffdf8f2e3d2e313425d /sources/hv-collector-utils/src | |
| parent | dc936d27d761bde31ac5916a84efa2f48ec32b83 (diff) | |
Support CBS request interval reconfiguration
Change-Id: Ie8892e33b2f6a58d6076f66e6cc6a2df830dfa48
Issue-ID: DCAEGEN2-1525
Signed-off-by: kjaniak <kornel.janiak@nokia.com>
Diffstat (limited to 'sources/hv-collector-utils/src')
| -rw-r--r-- | sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/rx/rx.kt | 6 |
1 files changed, 6 insertions, 0 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 ceccbcba..e1886055 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 @@ -26,8 +26,14 @@ package org.onap.dcae.collectors.veshv.utils.rx import org.reactivestreams.Publisher +import reactor.core.publisher.Flux import reactor.core.publisher.Mono import reactor.core.publisher.toMono +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()) } +} |