Fixed asConsumer signature

badoo · Apr 4, 2024 · e2985d4 · e2985d4
1 parent e67128e
commit e2985d4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...vicore-demo-app/src/main/java/com/badoo/mvicoredemo/ui/common/ObservableSourceActivity.kt b/...vicore-demo-app/src/main/java/com/badoo/mvicoredemo/ui/common/ObservableSourceActivity.kt
@@ -4,7 +4,7 @@ import io.reactivex.ObservableSource
 import io.reactivex.Observer
 import io.reactivex.subjects.PublishSubject
 
-abstract class ObservableSourceActivity<T> : DebugActivity(), ObservableSource<T> {
+abstract class ObservableSourceActivity<T : Any> : DebugActivity(), ObservableSource<T> {
 
     private val source = PublishSubject.create<T>()
 

diff --git a/mvicore/src/main/java/com/badoo/mvicore/extension/Rx.kt b/mvicore/src/main/java/com/badoo/mvicore/extension/Rx.kt
@@ -5,7 +5,7 @@ import io.reactivex.Observer
 import io.reactivex.Scheduler
 import io.reactivex.functions.Consumer
 
-fun <T> Observer<T>.asConsumer() = Consumer<T> { onNext(it) }
+fun <T : Any> Observer<T>.asConsumer() = Consumer<T> { onNext(it) }
 
 internal fun <T> Observable<T>.subscribeOnNullable(scheduler: Scheduler?): Observable<T> =
     if (scheduler != null) subscribeOn(scheduler) else this