refactor(takeUntil): change notifier type to Flow<Any?> (#112)

* Flow<*> * Flow<Any?>
hoc081098 · Jul 15, 2022 · 99c375d · 99c375d
1 parent dbba205
commit 99c375d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/commonMain/kotlin/com/hoc081098/flowext/takeUntil.kt b/src/commonMain/kotlin/com/hoc081098/flowext/takeUntil.kt
@@ -40,7 +40,7 @@ import kotlinx.coroutines.launch
  * @param notifier The [Flow] whose first emitted value or complete event
  * will cause the output [Flow] of [takeUntil] to stop emitting values from the source [Flow].
  */
-public fun <T, R> Flow<T>.takeUntil(notifier: Flow<R>): Flow<T> = flow {
+public fun <T> Flow<T>.takeUntil(notifier: Flow<Any?>): Flow<T> = flow {
   try {
     coroutineScope {
       val job = launch(start = CoroutineStart.UNDISPATCHED) {