From f50a60089cd68525b7d99b42b0474b3692e51d33 Mon Sep 17 00:00:00 2001 From: Roman Elizarov Date: Tue, 16 Jun 2020 11:23:48 +0300 Subject: [PATCH] ~ Fixup kotlinx-coroutines-rx3 module to internal API changes --- reactive/kotlinx-coroutines-rx3/src/RxChannel.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/reactive/kotlinx-coroutines-rx3/src/RxChannel.kt b/reactive/kotlinx-coroutines-rx3/src/RxChannel.kt index acb907b765..737cf6710d 100644 --- a/reactive/kotlinx-coroutines-rx3/src/RxChannel.kt +++ b/reactive/kotlinx-coroutines-rx3/src/RxChannel.kt @@ -54,7 +54,7 @@ public suspend inline fun ObservableSource.collect(action: (T) -> Unit): @Suppress("INVISIBLE_REFERENCE", "INVISIBLE_MEMBER") private class SubscriptionChannel : - LinkedListChannel(), Observer, MaybeObserver + LinkedListChannel(null), Observer, MaybeObserver { private val _subscription = atomic(null)