diff --git a/reaktive/src/commonMain/kotlin/com/badoo/reaktive/completable/CompletableEmitterSerialize.kt b/reaktive/src/commonMain/kotlin/com/badoo/reaktive/completable/CompletableEmitterSerialize.kt index 6619f5aae..69a24d853 100644 --- a/reaktive/src/commonMain/kotlin/com/badoo/reaktive/completable/CompletableEmitterSerialize.kt +++ b/reaktive/src/commonMain/kotlin/com/badoo/reaktive/completable/CompletableEmitterSerialize.kt @@ -12,7 +12,7 @@ private class SerializedCompletableEmitter( private val serializer = serializer { event -> when (event) { - is Event.OnComplete -> delegate.onComplete() + Event.OnComplete -> delegate.onComplete() is Event.OnError -> delegate.onError(event.error) } diff --git a/reaktive/src/commonMain/kotlin/com/badoo/reaktive/observable/ObservableEmitterSerialize.kt b/reaktive/src/commonMain/kotlin/com/badoo/reaktive/observable/ObservableEmitterSerialize.kt index f7a5f957d..2850538d5 100644 --- a/reaktive/src/commonMain/kotlin/com/badoo/reaktive/observable/ObservableEmitterSerialize.kt +++ b/reaktive/src/commonMain/kotlin/com/badoo/reaktive/observable/ObservableEmitterSerialize.kt @@ -13,7 +13,7 @@ private class SerializedObservableEmitter( serializer { event -> if (event is Event) { when (event) { - is Event.OnComplete -> delegate.onComplete() + Event.OnComplete -> delegate.onComplete() is Event.OnError -> delegate.onError(event.error) }