repeatOnLifecycle

[Muhammadali143904]

Hi, i have a question or idea, when i start learning mvi for compose, is see how we bind flow with lifecycle, under hood it calls this method:

So, in my opinion it will good to add this method for essenty, i try but it fails
Sources start with here - android.Lifecycle

[Muhammadali143904]

There are codes, which i try to merge with essenty
Archive.zip

[arkivanov]

This is just from the top of my head, but I guess it should work.

fun <T> Flow<T>.flowWithLifecycle(
    lifecycle: Lifecycle,
    minActiveState: Lifecycle.State = Lifecycle.State.STARTED,
): Flow<T> {
    require(minActiveState !== Lifecycle.State.INITIALIZED) {
        "flowWithLifecycle cannot start work with minActiveState = Lifecycle.State.INITIALIZED"
    }

    return callbackFlow {
        val scope = CoroutineScope(Dispatchers.Main.immediate)

        var job: Job? = null

        fun start() {
            job = scope.launch { collect { send(it) } }
        }

        fun stop() {
            job?.cancel()
            job = null
        }

        when (minActiveState) {
            Lifecycle.State.CREATED -> lifecycle.subscribe(onCreate = ::start, onDestroy = ::stop)
            Lifecycle.State.STARTED -> lifecycle.subscribe(onStart = ::start, onStop = ::stop)
            Lifecycle.State.RESUMED -> lifecycle.subscribe(onResume = ::start, onPause = ::stop)
            Lifecycle.State.DESTROYED,
            Lifecycle.State.INITIALIZED -> Unit
        }

        awaitClose { scope.cancel() }
    }
}

[Muhammadali143904]

Thank you