From c50b6606f4af4452d1b107929956775e86e366c1 Mon Sep 17 00:00:00 2001 From: Jakub Dudycz Date: Wed, 27 Feb 2019 10:16:01 +0100 Subject: Fix bug when xnf simulator was not sending events Change-Id: I53cdf572d2df66d6021651424931a67108c482d3 Signed-off-by: Jakub Dudycz Issue-ID: DCAEGEN2-1291 --- .../org/onap/dcae/collectors/veshv/simulators/xnf/impl/XnfSimulator.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'sources') diff --git a/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/XnfSimulator.kt b/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/XnfSimulator.kt index 812afe19..53a8826c 100644 --- a/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/XnfSimulator.kt +++ b/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/XnfSimulator.kt @@ -66,7 +66,7 @@ class XnfSimulator( private fun simulationFrom(parameters: List): IO = parameters .toFlux() - .map(::simulate) + .flatMap(::simulate) .then(Mono.just(Unit)) .asIo() -- cgit 1.2.3-korg