Get rid of @InternalCoroutinesApi from Flow.collect member (#3082)

* Get rid of @InternalCoroutinesApi from Flow.collect member

Fixes #3078

Author: qwwdfsad

integration/kotlinx-coroutines-jdk8/src/stream/Stream.kt

@@ -19,7 +19,6 @@ public fun <T> Stream<T>.consumeAsFlow(): Flow<T> = StreamFlow(this)
 private class StreamFlow<T>(private val stream: Stream<T>) : Flow<T> {
     private val consumed = atomic(false)
 
-    @InternalCoroutinesApi
     override suspend fun collect(collector: FlowCollector<T>) {
         if (!consumed.compareAndSet(false, true)) error("Stream.consumeAsFlow can be collected only once")
         try {

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

@@ -172,7 +172,7 @@ import kotlin.coroutines.*
  *
  * **The `Flow` interface is not stable for inheritance in 3rd party libraries**, as new methods
  * might be added to this interface in the future, but is stable for use.
- * Use the `flow { ... }` builder function to create an implementation.
+ * Use the `flow { ... }` builder function to create an implementation, or extend [AbstractFlow].
  */
 public interface Flow<out T> {
     /**
@@ -184,7 +184,6 @@ public interface Flow<out T> {
      * should be used. Such limitation ensures that the context preservation property is not violated and prevents most
      * of the developer mistakes related to concurrency, inconsistent flow dispatchers and cancellation.
      */
-    @InternalCoroutinesApi
     public suspend fun collect(collector: FlowCollector<T>)
 }
 
@@ -214,7 +213,6 @@ public interface Flow<out T> {
 @FlowPreview
 public abstract class AbstractFlow<T> : Flow<T>, CancellableFlow<T> {
 
-    @InternalCoroutinesApi
     public final override suspend fun collect(collector: FlowCollector<T>) {
         val safeCollector = SafeCollector(collector, coroutineContext)
         try {

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

@@ -140,7 +140,6 @@ public interface SharedFlow<out T> : Flow<T> {
      *
      * @see [Flow.collect]
      */
-    @InternalCoroutinesApi
     override suspend fun collect(collector: FlowCollector<T>): Nothing
 }
 

kotlinx-coroutines-core/common/src/flow/operators/Distinct.kt

@@ -71,7 +71,6 @@ private class DistinctFlowImpl<T>(
     @JvmField val keySelector: (T) -> Any?,
     @JvmField val areEquivalent: (old: Any?, new: Any?) -> Boolean
 ): Flow<T> {
-    @InternalCoroutinesApi
     override suspend fun collect(collector: FlowCollector<T>) {
         var previousKey: Any? = NULL
         upstream.collect { value ->