Optimized serialized emitters

badoo · Oct 23, 2019 · 8f3876b · 8f3876b
1 parent 5a1e3bb
commit 8f3876b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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> { 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
@@ -13,7 +13,7 @@ private class SerializedObservableEmitter<T>(
         serializer<Any?> { event ->
             if (event is Event) {
                 when (event) {
-                    is Event.OnComplete -> delegate.onComplete()
+                    Event.OnComplete -> delegate.onComplete()
                     is Event.OnError -> delegate.onError(event.error)
                 }