1 /*
2  *  Copyright (C) 2023 The Android Open Source Project
3  *
4  *  Licensed under the Apache License, Version 2.0 (the "License");
5  *  you may not use this file except in compliance with the License.
6  *  You may obtain a copy of the License at
7  *
8  *       http://www.apache.org/licenses/LICENSE-2.0
9  *
10  *  Unless required by applicable law or agreed to in writing, software
11  *  distributed under the License is distributed on an "AS IS" BASIS,
12  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  *  See the License for the specific language governing permissions and
14  *  limitations under the License.
15  *
16  */
17 package com.android.systemui.qs.tiles
18 
19 import androidx.lifecycle.Lifecycle
20 import androidx.lifecycle.LifecycleOwner
21 import androidx.lifecycle.lifecycleScope
22 import androidx.lifecycle.repeatOnLifecycle
23 import com.android.systemui.dagger.SysUISingleton
24 import java.util.function.Consumer
25 import javax.inject.Inject
26 import kotlinx.coroutines.flow.Flow
27 import kotlinx.coroutines.flow.collect
28 import kotlinx.coroutines.launch
29 
30 /**
31  * Utility for binding tiles to kotlin flows. Similar to [JavaAdapter] and usable for QS tiles. We
32  * use [Lifecycle.State.RESUMED] here to match the implementation of [CallbackController.observe]
33  */
34 @SysUISingleton
35 class TileJavaAdapter @Inject constructor() {
36     fun <T> bind(
37         lifecycleOwner: LifecycleOwner,
38         flow: Flow<T>,
39         consumer: Consumer<T>,
40     ) {
41         lifecycleOwner.lifecycleScope.launch {
42             lifecycleOwner.repeatOnLifecycle(Lifecycle.State.RESUMED) {
43                 flow.collect { consumer.accept(it) }
44             }
45         }
46     }
47 }
48