Merge "Run kotlin CallbackFlow on background dispatcher." into main

import kotlinx.coroutines.channels.awaitClose

import kotlinx.coroutines.flow.Flow

import kotlinx.coroutines.flow.callbackFlow

import kotlinx.coroutines.flow.flowOn

import kotlinx.coroutines.flow.map

import kotlinx.coroutines.flow.onStart

import kotlinx.coroutines.withContext

                awaitClose { context.contentResolver.unregisterContentObserver(observer) }

            }

            .onStart { emit(Unit) }

            .flowOn(backgroundDispatcher)

    }

    private fun String.toIntent(

import kotlinx.coroutines.CoroutineDispatcher

import kotlinx.coroutines.channels.awaitClose

import kotlinx.coroutines.flow.Flow

import kotlinx.coroutines.withContext

import kotlinx.coroutines.flow.flowOn

/** Utility class that could give information about if animation are enabled in the system */

interface AnimationStatusRepository {

     * Emits true if animations are enabled in the system, after subscribing it immediately emits

     * the current state

     */

    override fun areAnimationsEnabled(): Flow<Boolean> = conflatedCallbackFlow {

        val initialValue = withContext(backgroundDispatcher) { resolver.areAnimationsEnabled() }

    override fun areAnimationsEnabled(): Flow<Boolean> =

        conflatedCallbackFlow {

                val initialValue = resolver.areAnimationsEnabled()

                trySend(initialValue)

                val observer =

                awaitClose { resolver.unregisterContentObserver(observer) }

            }

            .flowOn(backgroundDispatcher)

}