feat(repeat): add repeat operator & kotlin 1.9.0 (hoc081098#174)

🔥

Author: hoc081098

CHANGELOG.md

@@ -2,11 +2,17 @@
 
 ## [Unreleased] - TODO
 
+### Changed
+
 - Update dependencies
-  - `Kotlin` to `1.8.22`.
+  - `Kotlin` to `1.9.0`.
   - `KotlinX Coroutines` to `1.7.2`.
   - `Gradle` to `8.2`.
 
+### Added
+
+- Add `Flow.repeat` operator.
+
 ## [0.6.1] - May 18, 2023
 
 ### Changed

README.md

@@ -149,6 +149,7 @@ dependencies {
   - [`raceWith`](#racewith--ambwith)
   - [`ambWith`](#racewith--ambwith)
   - [`pairwise`](#pairwise)
+  - [`repeat`](#repeat)
   - [`retryWhenWithDelayStrategy`](#retrywhenwithdelaystrategy)
   - [`retryWhenWithExponentialBackoff`](#retrywhenwithexponentialbackoff)
   - [`retryWithExponentialBackoff`](#retrywithexponentialbackoff)
@@ -849,6 +850,51 @@ pairwise: (2, 3)
 
 ----
 
+#### repeat
+
+- Similar to [RxJS repeat](https://rxjs.dev/api/index/function/repeat)
+
+Returns a `Flow` that will recollect to the source stream when the source stream completes.
+
+```kotlin
+flowFromSuspend {
+  println("Start collecting...")
+
+  Random
+    .nextInt(0..3)
+    .also { println("Emit: $it") }
+}
+  .repeat(
+    delay = 1.seconds,
+    count = 10
+  )
+  .filter { it == 2 }
+  .take(1)
+  .collect { println("repeat: $it") }
+```
+
+Output:
+
+```none
+Start collecting...
+Emit: 1
+Start collecting...
+Emit: 3
+Start collecting...
+Emit: 1
+Start collecting...
+Emit: 0
+Start collecting...
+Emit: 1
+Start collecting...
+Emit: 3
+Start collecting...
+Emit: 2
+repeat: 2
+```
+
+----
+
 #### retryWhenWithDelayStrategy
 
 Retries collection of the given flow when an exception occurs in the upstream flow and the

api/FlowExt.api

@@ -81,6 +81,8 @@ public abstract interface class com/hoc081098/flowext/Event {
 
 public final class com/hoc081098/flowext/Event$Complete : com/hoc081098/flowext/Event {
 	public static final field INSTANCE Lcom/hoc081098/flowext/Event$Complete;
+	public fun equals (Ljava/lang/Object;)Z
+	public fun hashCode ()I
 	public fun toString ()Ljava/lang/String;
 }
 
@@ -191,6 +193,15 @@ public final class com/hoc081098/flowext/RangeKt {
 	public static final fun range (II)Lkotlinx/coroutines/flow/Flow;
 }
 
+public final class com/hoc081098/flowext/RepeatKt {
+	public static final fun repeat (Lkotlinx/coroutines/flow/Flow;)Lkotlinx/coroutines/flow/Flow;
+	public static final fun repeat (Lkotlinx/coroutines/flow/Flow;I)Lkotlinx/coroutines/flow/Flow;
+	public static final fun repeat (Lkotlinx/coroutines/flow/Flow;ILkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/flow/Flow;
+	public static final fun repeat (Lkotlinx/coroutines/flow/Flow;Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/flow/Flow;
+	public static final fun repeat-HG0u8IE (Lkotlinx/coroutines/flow/Flow;J)Lkotlinx/coroutines/flow/Flow;
+	public static final fun repeat-SxA4cEA (Lkotlinx/coroutines/flow/Flow;IJ)Lkotlinx/coroutines/flow/Flow;
+}
+
 public final class com/hoc081098/flowext/RetryWhenWithDelayStrategyKt {
 	public static final fun retryWhenWithDelayStrategy (Lkotlinx/coroutines/flow/Flow;Lcom/hoc081098/flowext/DelayStrategy;Lkotlin/jvm/functions/Function4;)Lkotlinx/coroutines/flow/Flow;
 	public static final fun retryWhenWithExponentialBackoff-7Q0yyfQ (Lkotlinx/coroutines/flow/Flow;JDJLkotlin/jvm/functions/Function4;)Lkotlinx/coroutines/flow/Flow;
@@ -220,6 +231,7 @@ public final class com/hoc081098/flowext/ThrottleConfiguration : java/lang/Enum
 	public static final field LEADING Lcom/hoc081098/flowext/ThrottleConfiguration;
 	public static final field LEADING_AND_TRAILING Lcom/hoc081098/flowext/ThrottleConfiguration;
 	public static final field TRAILING Lcom/hoc081098/flowext/ThrottleConfiguration;
+	public static fun getEntries ()Lkotlin/enums/EnumEntries;
 	public static fun valueOf (Ljava/lang/String;)Lcom/hoc081098/flowext/ThrottleConfiguration;
 	public static fun values ()[Lcom/hoc081098/flowext/ThrottleConfiguration;
 }

build.gradle.kts

@@ -9,7 +9,7 @@ import org.jetbrains.kotlin.gradle.plugin.mpp.NativeBuildType
 import java.net.URL
 
 plugins {
-  kotlin("multiplatform") version "1.8.22"
+  kotlin("multiplatform") version "1.9.0"
   id("com.diffplug.spotless") version "6.19.0"
   id("maven-publish")
   id("com.vanniktech.maven.publish") version "0.25.3"
@@ -49,12 +49,16 @@ kotlin {
     }
     browser {
       testTask {
-        useMocha()
+        useMocha {
+          timeout = "10s"
+        }
       }
     }
     nodejs {
       testTask {
-        useMocha()
+        useMocha {
+          timeout = "10s"
+        }
       }
     }
   }