Add flowOf(value), use unsafeFlow in trivial flow builders

Author: qwwdfsad

binary-compatibility-validator/reference-public-api/kotlinx-coroutines-core.txt

@@ -813,6 +813,7 @@ public final class kotlinx/coroutines/flow/FlowKt {
 	public static final fun flattenMerge (Lkotlinx/coroutines/flow/Flow;II)Lkotlinx/coroutines/flow/Flow;
 	public static synthetic fun flattenMerge$default (Lkotlinx/coroutines/flow/Flow;IIILjava/lang/Object;)Lkotlinx/coroutines/flow/Flow;
 	public static final fun flow (Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/flow/Flow;
+	public static final fun flowOf (Ljava/lang/Object;)Lkotlinx/coroutines/flow/Flow;
 	public static final fun flowOf ([Ljava/lang/Object;)Lkotlinx/coroutines/flow/Flow;
 	public static final fun flowOn (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;I)Lkotlinx/coroutines/flow/Flow;
 	public static synthetic fun flowOn$default (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;IILjava/lang/Object;)Lkotlinx/coroutines/flow/Flow;

kotlinx-coroutines-core/common/src/flow/Builders.kt

@@ -127,6 +127,18 @@ public fun <T> flowOf(vararg elements: T): Flow<T> = unsafeFlow {
     }
 }
 
+/**
+ * Creates flow that produces a given [value].
+ */
+@FlowPreview
+public fun <T> flowOf(value: T): Flow<T> = unsafeFlow {
+    /*
+     * Implementation note: this is just an "optimized" overload of flowOf(vararg)
+     * which significantly reduce the footprint of widespread single-value flows.
+     */
+    emit(value)
+}
+
 /**
  * Returns an empty flow.
  */
@@ -141,7 +153,7 @@ private object EmptyFlow : Flow<Nothing> {
  * Creates a flow that produces values from the given array.
  */
 @FlowPreview
-public fun <T> Array<T>.asFlow(): Flow<T> = flow {
+public fun <T> Array<T>.asFlow(): Flow<T> = unsafeFlow {
     forEach { value ->
         emit(value)
     }
@@ -151,7 +163,7 @@ public fun <T> Array<T>.asFlow(): Flow<T> = flow {
  * Creates flow that produces values from the given array.
  */
 @FlowPreview
-public fun IntArray.asFlow(): Flow<Int> = flow {
+public fun IntArray.asFlow(): Flow<Int> = unsafeFlow {
     forEach { value ->
         emit(value)
     }
@@ -161,7 +173,7 @@ public fun IntArray.asFlow(): Flow<Int> = flow {
  * Creates flow that produces values from the given array.
  */
 @FlowPreview
-public fun LongArray.asFlow(): Flow<Long> = flow {
+public fun LongArray.asFlow(): Flow<Long> = unsafeFlow {
     forEach { value ->
         emit(value)
     }
@@ -171,7 +183,7 @@ public fun LongArray.asFlow(): Flow<Long> = flow {
  * Creates flow that produces values from the given range.
  */
 @FlowPreview
-public fun IntRange.asFlow(): Flow<Int> = flow {
+public fun IntRange.asFlow(): Flow<Int> = unsafeFlow {
     forEach { value ->
         emit(value)
     }