From 3d6feef167f8e8eb716312599132c41dd89457cb Mon Sep 17 00:00:00 2001
From: Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
Date: Mon, 3 Jun 2019 14:20:40 +0200
Subject: Monitoring API - write framework adapters

Change-Id: Iaba9c4ef6022d01c1f572055316700a3a4dfa8f2
Issue-ID: DCAEGEN2-1589
Signed-off-by: Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
---
 .../services/sdk/standardization/moher/metrics/impl/MetricsImpl.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'standardization/moher-api/metrics')

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")
-- 
cgit 1.2.3-korg