[CS] Define an #alwaysCollectFlow method that can be used from Java.

import android.view.View

import androidx.lifecycle.Lifecycle

import androidx.lifecycle.repeatOnLifecycle

import com.android.systemui.dagger.SysUISingleton

import com.android.systemui.dagger.qualifiers.Application

import com.android.systemui.lifecycle.repeatWhenAttached

import java.util.function.Consumer

import javax.inject.Inject

import kotlin.coroutines.CoroutineContext

import kotlin.coroutines.EmptyCoroutineContext

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Job

import kotlinx.coroutines.flow.Flow

import kotlinx.coroutines.flow.collect

import kotlinx.coroutines.launch

/** A class allowing Java classes to collect on Kotlin flows. */

@SysUISingleton

class JavaAdapter

@Inject

constructor(

    @Application private val scope: CoroutineScope,

) {

    /**

     * Collect information for the given [flow], calling [consumer] for each emitted event.

     *

     * Important: This will immediately start collection and *never* stop it. This should only be

     * used by classes that *need* to always be collecting a value and processing it. Whenever

     * possible, please use [collectFlow] instead; that method will stop the collection when a view

     * has disappeared, which will ensure that we don't perform unnecessary work.

     *

     * Do *not* call this method in a class's constructor. Instead, call it in

     * [com.android.systemui.CoreStartable.start] or similar method.

     */

    fun <T> alwaysCollectFlow(

        flow: Flow<T>,

        consumer: Consumer<T>,

    ): Job {

        return scope.launch { flow.collect { consumer.accept(it) } }

    }

}

/**

 * Collect information for the given [flow], calling [consumer] for each emitted event. Defaults to