From 5180f3f32a2cdd35206f728e0fd7dd6ad62b567a Mon Sep 17 00:00:00 2001 From: Filip Krzywka Date: Tue, 8 Jan 2019 07:53:25 +0100 Subject: Merge Healthcheck descriptions - start new API server for healthchecks in xNF simulator on port 6063 - changed DCAE App default port to 6064 - switched to InetSocketAddresses usage in components configurations Change-Id: I398f9ea6e887f78d88286ed717d310d3297b1571 Issue-ID: DCAEGEN2-1063 Signed-off-by: Filip Krzywka --- .../main/kotlin/org/onap/dcae/collectors/veshv/utils/arrow/effects.kt | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'sources/hv-collector-utils/src/main') diff --git a/sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/arrow/effects.kt b/sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/arrow/effects.kt index 05d13094..3c2c64ac 100644 --- a/sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/arrow/effects.kt +++ b/sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/arrow/effects.kt @@ -46,10 +46,9 @@ object ExitSuccess : ExitCode() { data class ExitFailure(override val code: Int) : ExitCode() -fun Either, IO>.unsafeRunEitherSync(onError: (Throwable) -> ExitCode, onSuccess: () -> Unit) = +fun Either, IO>.unsafeRunEitherSync(onError: (Throwable) -> ExitCode, onSuccess: () -> Unit) = flatten().attempt().unsafeRunSync().fold({ onError(it).io().unsafeRunSync() }, { onSuccess() }) - fun IO.unit() = map { Unit } fun Mono.asIo() = IO.async { callback -> -- cgit 1.2.3-korg