Remove the @ExperimentalCoroutinesApi annotation from reactive integrations (#2670)

Author: dkhalanskyjb

reactive/kotlinx-coroutines-jdk9/src/Publish.kt

@@ -32,7 +32,6 @@ import org.reactivestreams.FlowAdapters
  *
  * @throws IllegalArgumentException if the provided [context] contains a [Job] instance.
  */
-@ExperimentalCoroutinesApi
 public fun <T> flowPublish(
     context: CoroutineContext = EmptyCoroutineContext,
     @BuilderInference block: suspend ProducerScope<T>.() -> Unit

reactive/kotlinx-coroutines-reactive/src/Publish.kt

@@ -32,7 +32,6 @@ import kotlin.coroutines.*
  *
  * @throws IllegalArgumentException if the provided [context] contains a [Job] instance.
  */
-@ExperimentalCoroutinesApi
 public fun <T> publish(
     context: CoroutineContext = EmptyCoroutineContext,
     @BuilderInference block: suspend ProducerScope<T>.() -> Unit

reactive/kotlinx-coroutines-reactor/src/Convert.kt

@@ -21,7 +21,6 @@ import kotlin.coroutines.*
  *
  * @param context -- the coroutine context from which the resulting mono is going to be signalled
  */
-@ExperimentalCoroutinesApi
 public fun Job.asMono(context: CoroutineContext): Mono<Unit> = mono(context) { this@asMono.join() }
 /**
  * Converts this deferred value to the hot reactive mono that signals
@@ -35,7 +34,6 @@ public fun Job.asMono(context: CoroutineContext): Mono<Unit> = mono(context) { t
  *
  * @param context -- the coroutine context from which the resulting mono is going to be signalled
  */
-@ExperimentalCoroutinesApi
 public fun <T> Deferred<T?>.asMono(context: CoroutineContext): Mono<T> = mono(context) { this@asMono.await() }
 
 /**

reactive/kotlinx-coroutines-reactor/src/Flux.kt

@@ -29,7 +29,6 @@ import kotlin.coroutines.*
  *
  * @throws IllegalArgumentException if the provided [context] contains a [Job] instance.
  */
-@ExperimentalCoroutinesApi
 public fun <T> flux(
     context: CoroutineContext = EmptyCoroutineContext,
     @BuilderInference block: suspend ProducerScope<T>.() -> Unit

reactive/kotlinx-coroutines-reactor/src/ReactorContext.kt

@@ -49,7 +49,6 @@ import reactor.util.context.*
  *     .subscribe() // Will print "Reactor context in Flow: Context{'answer'=42}"
  * ```
  */
-@ExperimentalCoroutinesApi
 public class ReactorContext(public val context: Context) : AbstractCoroutineContextElement(ReactorContext) {
 
     // `Context.of` is zero-cost if the argument is a `Context`
@@ -62,14 +61,12 @@ public class ReactorContext(public val context: Context) : AbstractCoroutineCont
  * Wraps the given [ContextView] into [ReactorContext], so it can be added to the coroutine's context
  * and later used via `coroutineContext[ReactorContext]`.
  */
-@ExperimentalCoroutinesApi
 public fun ContextView.asCoroutineContext(): ReactorContext = ReactorContext(this)
 
 /**
  * Wraps the given [Context] into [ReactorContext], so it can be added to the coroutine's context
  * and later used via `coroutineContext[ReactorContext]`.
  */
-@ExperimentalCoroutinesApi
 @Deprecated("The more general version for ContextView should be used instead", level = DeprecationLevel.HIDDEN)
 public fun Context.asCoroutineContext(): ReactorContext = readOnly().asCoroutineContext() // `readOnly()` is zero-cost.
 

reactive/kotlinx-coroutines-rx2/src/RxConvert.kt

@@ -26,7 +26,6 @@ import kotlin.coroutines.*
  *
  * @param context -- the coroutine context from which the resulting completable is going to be signalled
  */
-@ExperimentalCoroutinesApi
 public fun Job.asCompletable(context: CoroutineContext): Completable = rxCompletable(context) {
     this@asCompletable.join()
 }
@@ -43,7 +42,6 @@ public fun Job.asCompletable(context: CoroutineContext): Completable = rxComplet
  *
  * @param context -- the coroutine context from which the resulting maybe is going to be signalled
  */
-@ExperimentalCoroutinesApi
 public fun <T> Deferred<T?>.asMaybe(context: CoroutineContext): Maybe<T> = rxMaybe(context) {
     this@asMaybe.await()
 }
@@ -60,7 +58,6 @@ public fun <T> Deferred<T?>.asMaybe(context: CoroutineContext): Maybe<T> = rxMay
  *
  * @param context -- the coroutine context from which the resulting single is going to be signalled
  */
-@ExperimentalCoroutinesApi
 public fun <T : Any> Deferred<T>.asSingle(context: CoroutineContext): Single<T> = rxSingle(context) {
     this@asSingle.await()
 }
@@ -75,7 +72,6 @@ public fun <T : Any> Deferred<T>.asSingle(context: CoroutineContext): Single<T>
  * resulting flow to specify a user-defined value and to control what happens when data is produced faster
  * than consumed, i.e. to control the back-pressure behavior. Check [callbackFlow] for more details.
  */
-@ExperimentalCoroutinesApi
 public fun <T: Any> ObservableSource<T>.asFlow(): Flow<T> = callbackFlow {
     val disposableRef = AtomicReference<Disposable>()
     val observer = object : Observer<T> {
@@ -108,7 +104,6 @@ public fun <T: Any> ObservableSource<T>.asFlow(): Flow<T> = callbackFlow {
  * inject additional context into the caller thread. By default, the [Unconfined][Dispatchers.Unconfined] dispatcher
  * is used, so calls are performed from an arbitrary thread.
  */
-@ExperimentalCoroutinesApi
 public fun <T: Any> Flow<T>.asObservable(context: CoroutineContext = EmptyCoroutineContext) : Observable<T> = Observable.create { emitter ->
     /*
      * ATOMIC is used here to provide stable behaviour of subscribe+dispose pair even if
@@ -141,7 +136,6 @@ public fun <T: Any> Flow<T>.asObservable(context: CoroutineContext = EmptyCorout
  * inject additional context into the caller thread. By default, the [Unconfined][Dispatchers.Unconfined] dispatcher
  * is used, so calls are performed from an arbitrary thread.
  */
-@ExperimentalCoroutinesApi
 public fun <T: Any> Flow<T>.asFlowable(context: CoroutineContext = EmptyCoroutineContext): Flowable<T> =
     Flowable.fromPublisher(asPublisher(context))
 

reactive/kotlinx-coroutines-rx2/src/RxFlowable.kt

@@ -31,7 +31,6 @@ import kotlin.internal.*
  *
  * **Note: This is an experimental api.** Behaviour of publishers that work as children in a parent scope with respect
  */
-@ExperimentalCoroutinesApi
 public fun <T: Any> rxFlowable(
     context: CoroutineContext = EmptyCoroutineContext,
     @BuilderInference block: suspend ProducerScope<T>.() -> Unit

reactive/kotlinx-coroutines-rx2/src/RxObservable.kt

@@ -30,7 +30,6 @@ import kotlin.coroutines.*
  * If the context does not have any dispatcher nor any other [ContinuationInterceptor], then [Dispatchers.Default] is used.
  * Method throws [IllegalArgumentException] if provided [context] contains a [Job] instance.
  */
-@ExperimentalCoroutinesApi
 public fun <T : Any> rxObservable(
     context: CoroutineContext = EmptyCoroutineContext,
     @BuilderInference block: suspend ProducerScope<T>.() -> Unit

reactive/kotlinx-coroutines-rx3/src/RxConvert.kt

@@ -26,7 +26,6 @@ import kotlin.coroutines.*
  *
  * @param context -- the coroutine context from which the resulting completable is going to be signalled
  */
-@ExperimentalCoroutinesApi
 public fun Job.asCompletable(context: CoroutineContext): Completable = rxCompletable(context) {
     this@asCompletable.join()
 }
@@ -43,7 +42,6 @@ public fun Job.asCompletable(context: CoroutineContext): Completable = rxComplet
  *
  * @param context -- the coroutine context from which the resulting maybe is going to be signalled
  */
-@ExperimentalCoroutinesApi
 public fun <T> Deferred<T?>.asMaybe(context: CoroutineContext): Maybe<T> = rxMaybe(context) {
     this@asMaybe.await()
 }
@@ -60,7 +58,6 @@ public fun <T> Deferred<T?>.asMaybe(context: CoroutineContext): Maybe<T> = rxMay
  *
  * @param context -- the coroutine context from which the resulting single is going to be signalled
  */
-@ExperimentalCoroutinesApi
 public fun <T : Any> Deferred<T>.asSingle(context: CoroutineContext): Single<T> = rxSingle(context) {
     this@asSingle.await()
 }
@@ -75,7 +72,6 @@ public fun <T : Any> Deferred<T>.asSingle(context: CoroutineContext): Single<T>
  * resulting flow to specify a user-defined value and to control what happens when data is produced faster
  * than consumed, i.e. to control the back-pressure behavior. Check [callbackFlow] for more details.
  */
-@ExperimentalCoroutinesApi
 public fun <T: Any> ObservableSource<T>.asFlow(): Flow<T> = callbackFlow {
     val disposableRef = AtomicReference<Disposable>()
     val observer = object : Observer<T> {
@@ -108,7 +104,6 @@ public fun <T: Any> ObservableSource<T>.asFlow(): Flow<T> = callbackFlow {
  * inject additional context into the caller thread. By default, the [Unconfined][Dispatchers.Unconfined] dispatcher
  * is used, so calls are performed from an arbitrary thread.
  */
-@ExperimentalCoroutinesApi
 public fun <T: Any> Flow<T>.asObservable(context: CoroutineContext = EmptyCoroutineContext) : Observable<T> = Observable.create { emitter ->
     /*
      * ATOMIC is used here to provide stable behaviour of subscribe+dispose pair even if
@@ -141,7 +136,6 @@ public fun <T: Any> Flow<T>.asObservable(context: CoroutineContext = EmptyCorout
  * inject additional context into the caller thread. By default, the [Unconfined][Dispatchers.Unconfined] dispatcher
  * is used, so calls are performed from an arbitrary thread.
  */
-@ExperimentalCoroutinesApi
 public fun <T: Any> Flow<T>.asFlowable(context: CoroutineContext = EmptyCoroutineContext): Flowable<T> =
     Flowable.fromPublisher(asPublisher(context))
 

reactive/kotlinx-coroutines-rx3/src/RxFlowable.kt

@@ -28,7 +28,6 @@ import kotlin.coroutines.*
  *
  * **Note: This is an experimental api.** Behaviour of publishers that work as children in a parent scope with respect
  */
-@ExperimentalCoroutinesApi
 public fun <T: Any> rxFlowable(
     context: CoroutineContext = EmptyCoroutineContext,
     @BuilderInference block: suspend ProducerScope<T>.() -> Unit