krossovochkin

fun hiThere(): Single<Int> {
    return Completable.timer(1, TimeUnit.SECONDS)
        .andThen(Single.just(40))
        .subscribeOn(computation())
}
fun test() {
    Observable.just(1)
        .flatMapSingle { hiThere() }
        .subscribeOn(io())
        .subscribe { println(it) }

krossovochkin

suspend fun hiThere(): Int {
    return withContext(Dispatchers.Default) {
        delay(1000)
        40
    }
}
@Test
fun test() {
    CoroutineScope(Job()).launch {
        flowOf(1)

krossovochkin

class TestViewModel : MyViewModel() {

    init {
        scope.launch(
            Observable.just("10")
                .subscribe { println("Something") }
        )

        Observable.just("10")
            .doOnNext { println("something") }

krossovochkin

package by.krossovochkin.testflow

import io.reactivex.Observable
import io.reactivex.schedulers.Schedulers.computation
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.channels.ReceiveChannel
import kotlinx.coroutines.channels.produce
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.selects.select

krossovochkin

package by.krossovochkin.testflow

import io.reactivex.Observable
import io.reactivex.exceptions.CompositeException
import io.reactivex.schedulers.Schedulers
import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
import org.junit.Test
import java.util.concurrent.CopyOnWriteArrayList
import java.util.concurrent.CountDownLatch

krossovochkin

private fun setTheme(theme: ThemeManager.Theme, animate: Boolean = true) {
    if (!animate) {
        ThemeManager.theme = theme
        return
    }

    if (imageView.isVisible) {
        return
    }

krossovochkin

class MainActivity : AppCompatActivity() {

    override fun onCreate(savedInstanceState: Bundle?) {
        LayoutInflaterCompat.setFactory2(
            LayoutInflater.from(this),
            MyLayoutInflater(delegate)
        )

        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)

krossovochkin

class MyLayoutInflater(
    private val delegate: AppCompatDelegate
) : LayoutInflater.Factory2 {

    override fun onCreateView(
        parent: View?,
        name: String,
        context: Context,
        attrs: AttributeSet
    ): View? {

krossovochkin

class MyTextView
@JvmOverloads
constructor(
    context: Context,
    attrs: AttributeSet? = null,
    defStyleAttr: Int = 0
) : AppCompatTextView(context, attrs, defStyleAttr),
    ThemeManager.ThemeChangedListener {

    override fun onFinishInflate() {

krossovochkin

object ThemeManager {

    private val listeners = mutableSetOf<ThemeChangedListener>()
    var theme = Theme.LIGHT
        set(value) {
            field = value
            listeners.forEach { listener -> listener.onThemeChanged(value) }
        }
        
    interface ThemeChangedListener {