[1.4.0-feature] 增加repeatOnLifecycle扩展函数

crazyqiang · crazyqiang · commit e0190f7cd76b · 2021-10-19T19:35:23.000+08:00
diff --git a/app/src/main/java/org/ninetripods/mq/study/kotlin/flow/FlowStudyActivity.kt b/app/src/main/java/org/ninetripods/mq/study/kotlin/flow/FlowStudyActivity.kt
@@ -131,7 +131,8 @@ class FlowStudyActivity : BaseActivity() {
                         mTvConvertSF.text = builder.toString()
                     }
                 }
-                //NOTE:&#36319;Flow.flowWithLifecycle&#25928;&#26524;&#19968;&#33268;
+                //1&#12289;&#21487;&#20197;&#25226;&#36825;&#37324;&#36890;&#36807;&#25193;&#23637;&#20989;&#25968;&#36827;&#34892;&#23553;&#35013; &#22914;&#65306;mFlowModel.flowConvertStateFlow.launchAndCollectIn(this) {}
+                //2&#12289;NOTE:&#36319;Flow.flowWithLifecycle&#25928;&#26524;&#19968;&#33268;
 //                mFlowModel.flowConvertStateFlow
 //                    .flowWithLifecycle(lifecycle, Lifecycle.State.STARTED)
 //                    .collect {
diff --git a/app/src/main/java/org/ninetripods/mq/study/kotlin/ktx/JetpackExt.kt b/app/src/main/java/org/ninetripods/mq/study/kotlin/ktx/JetpackExt.kt
@@ -1,11 +1,44 @@
 package org.ninetripods.mq.study.kotlin.ktx
 
-import androidx.lifecycle.LifecycleOwner
-import androidx.lifecycle.LiveData
+import androidx.fragment.app.Fragment
+import androidx.lifecycle.*
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.collect
+import kotlinx.coroutines.launch
 
 /**
  * LiveData&#25193;&#23637;&#20989;&#25968;&#23553;&#35013;
  */
 fun <T> LifecycleOwner.observe(liveData: LiveData<T>, observer: (t: T) -> Unit) {
     liveData.observe(this, { observer(it) })
 }
+
+/**
+ * repeatOnLifecycle: https://juejin.cn/post/7001371050202103838
+ */
+inline fun <T> Flow<T>.launchAndCollectIn(
+    owner: LifecycleOwner,
+    minActiveState: Lifecycle.State = Lifecycle.State.STARTED,
+    crossinline action: suspend CoroutineScope.(T) -> Unit
+) = owner.lifecycleScope.launch {
+    owner.lifecycle.repeatOnLifecycle(minActiveState) {
+        collect {
+            action(it)
+        }
+    }
+}
+
+/**
+ * Fragment&#20013;&#20351;&#29992;repeatOnLifecycle
+ */
+inline fun Fragment.launchAndRepeatWithViewLifecycle(
+    minActiveState: Lifecycle.State = Lifecycle.State.STARTED,
+    crossinline block: suspend CoroutineScope.() -> Unit
+) {
+    viewLifecycleOwner.lifecycleScope.launch {
+        viewLifecycleOwner.lifecycle.repeatOnLifecycle(minActiveState) {
+            block()
+        }
+    }
+}

Original file line number	Diff line number	Diff line change
`@@ -131,7 +131,8 @@ class FlowStudyActivity : BaseActivity() {`
`131`	`131`	`mTvConvertSF.text = builder.toString()`
`132`	`132`	`}`
`133`	`133`	`}`
`134`		`- //NOTE:跟Flow.flowWithLifecycle效果一致`
	`134`	`+ //1、可以把这里通过扩展函数进行封装如：mFlowModel.flowConvertStateFlow.launchAndCollectIn(this) {}`
	`135`	`+ //2、NOTE:跟Flow.flowWithLifecycle效果一致`
`135`	`136`	`// mFlowModel.flowConvertStateFlow`
`136`	`137`	`// .flowWithLifecycle(lifecycle, Lifecycle.State.STARTED)`
`137`	`138`	`// .collect {`