Signal/Android
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Android.git synced 2025-12-22 20:18:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Allow users to select a compact tab bar.

Browse Source
This commit is contained in:
Alex Hart
2023-04-13 14:19:47 -03:00
committed by Cody Henthorne
parent 06f19aa6cd
commit 09cf8074aa
20 changed files with 1354 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
core-util/src/main/java/org/signal/core/util/concurrent/RxExtensions.kt
View File

@@ -3,7 +3,11 @@
package org.signal.core.util.concurrent
import android.annotation.SuppressLint
import androidx.lifecycle.LifecycleOwner
import io.reactivex.rxjava3.core.Completable
import io.reactivex.rxjava3.core.Flowable
import io.reactivex.rxjava3.core.Single
import io.reactivex.rxjava3.kotlin.subscribeBy
import java.lang.RuntimeException
/**
@@ -26,3 +30,15 @@ fun <T : Any> Single<T>.safeBlockingGet(): T {
}
}
}
fun <T : Any> Flowable<T>.observe(viewLifecycleOwner: LifecycleOwner, onNext: (T) -> Unit) {
val lifecycleDisposable = LifecycleDisposable()
lifecycleDisposable.bindTo(viewLifecycleOwner)
lifecycleDisposable += subscribeBy(onNext = onNext)
}
fun Completable.observe(viewLifecycleOwner: LifecycleOwner, onComplete: () -> Unit) {
val lifecycleDisposable = LifecycleDisposable()
lifecycleDisposable.bindTo(viewLifecycleOwner)
lifecycleDisposable += subscribeBy(onComplete = onComplete)
}