add flowExt

Author: hoc081098

app/build.gradle.kts

@@ -102,6 +102,7 @@ dependencies {
 
   implementation(deps.listenableFuture)
   implementation(deps.viewBindingDelegate)
+  implementation(deps.flowExt)
 }
 
 apply {

app/src/main/java/com/hoc/comicapp/data/repository/DownloadComicsRepositoryImpl.kt

@@ -41,6 +41,7 @@ import com.hoc.comicapp.domain.thread.RxSchedulerProvider
 import com.hoc.comicapp.utils.copyTo
 import com.hoc.comicapp.utils.retryIO
 import com.hoc.comicapp.worker.DownloadComicWorker
+import com.hoc081098.flowext.utils.NULL_VALUE
 import io.reactivex.rxjava3.core.Observable
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.flow.Flow
@@ -457,12 +458,6 @@ private fun String.escapeFileName(): String {
   )
 }
 
-private object NULL {
-  @Suppress("UNCHECKED_CAST", "NOTHING_TO_INLINE")
-  inline fun <T : Any?> unbox(value: Any?): T =
-    if (NULL === value) null as T else value as T
-}
-
 /**
  * Collects all the values from the given flow, transform them by [transformer] and emits them to the [collector].
  * It is a shorthand for `flow.collect { value -> emit(value) }`.
@@ -473,10 +468,10 @@ private suspend fun <T, R> Flow<T>.emitAllTo(
   collector: FlowCollector<R>,
   transformer: (T) -> R,
 ): T? {
-  var last: Any? = NULL
+  var last: Any? = NULL_VALUE
   collect {
     last = it
     collector.emit(transformer(it))
   }
-  return NULL.unbox(last)
+  return NULL_VALUE.unbox(last)
 }

buildSrc/src/main/kotlin/Configurations.kt

@@ -87,6 +87,7 @@ object versions {
   const val arrow = "1.1.2"
   const val uri = "0.3.3"
   const val viewBindingDelegate = "1.3.1"
+  const val flowExt = "0.3.0-SNAPSHOT"
 }
 
 object deps {
@@ -211,6 +212,7 @@ object deps {
   }
 
   const val listenableFuture = "com.google.guava:listenablefuture:9999.0-empty-to-avoid-conflict-with-guava"
+  const val flowExt = "io.github.hoc081098:FlowExt:${versions.flowExt}"
   const val viewBindingDelegate = "com.github.hoc081098:ViewBindingDelegate:${versions.viewBindingDelegate}"
 }