aboutsummaryrefslogtreecommitdiffstats
path: root/standardization/moher-api/metrics
diff options
context:
space:
mode:
authorPiotr Wielebski <piotr.wielebski@nokia.com>2019-06-12 11:56:13 +0000
committerGerrit Code Review <gerrit@onap.org>2019-06-12 11:56:13 +0000
commita5b37327f23ec512e2ab64394ec4029e773af238 (patch)
tree3b397ea1c476b66b179f5f7f8d44b590439b6e75 /standardization/moher-api/metrics
parente655bbdb2e7d17660b34c7af236e7afb4ccda25a (diff)
parent3d6feef167f8e8eb716312599132c41dd89457cb (diff)
Merge "Monitoring API - write framework adapters"
Diffstat (limited to 'standardization/moher-api/metrics')
-rw-r--r--standardization/moher-api/metrics/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/metrics/impl/MetricsImpl.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/standardization/moher-api/metrics/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/metrics/impl/MetricsImpl.java b/standardization/moher-api/metrics/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/metrics/impl/MetricsImpl.java
index e592d976..8ccce84d 100644
--- a/standardization/moher-api/metrics/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/metrics/impl/MetricsImpl.java
+++ b/standardization/moher-api/metrics/src/main/java/org/onap/dcaegen2/services/sdk/standardization/moher/metrics/impl/MetricsImpl.java
@@ -42,13 +42,13 @@ public class MetricsImpl implements Metrics {
@Override
public Mono<String> collect() {
- return Mono.just(registry.scrape());
+ return Mono.fromCallable(registry::scrape);
}
@Override
public Flux<String> collect(Duration interval) {
return Flux.interval(interval)
- .map((l) -> registry.scrape());
+ .map(l -> registry.scrape());
}
@SuppressWarnings("squid:S2095")