Small fixes

Author: dkhalanskyjb

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

@@ -11,15 +11,14 @@ import org.reactivestreams.*
 import reactor.core.*
 import reactor.core.publisher.*
 import reactor.util.context.*
-import java.lang.IllegalArgumentException
 import kotlin.coroutines.*
 
 /**
- * Creates a cold reactive [Flux] that runs a given [block] in a coroutine.
+ * Creates a cold reactive [Flux] that runs the given [block] in a coroutine.
  * Every time the returned flux is subscribed, it starts a new coroutine in the specified [context].
- * Coroutine emits ([Subscriber.onNext]) values with [send][ProducerScope.send], completes ([Subscriber.onComplete])
- * when the coroutine completes, or the channel is explicitly closed and emits an error ([Subscriber.onError])
- * if the coroutine throws an exception or closes the channel with a cause.
+ * The coroutine emits ([Subscriber.onNext]) values with [send][ProducerScope.send], completes ([Subscriber.onComplete])
+ * when the coroutine completes, or, in case the coroutine throws an exception or the channel is closed,
+ * emits the error ([Subscriber.onError]) and closes the channel with the cause.
  * Unsubscribing cancels the running coroutine.
  *
  * Invocations of [send][ProducerScope.send] are suspended appropriately when subscribers apply back-pressure and to

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

@@ -12,12 +12,12 @@ import reactor.util.context.*
 /**
  * Wraps Reactor's [Context] into a [CoroutineContext] element for seamless integration between
  * Reactor and kotlinx.coroutines.
- * [Context.asCoroutineContext] is defined to place Reactor's [Context] elements into a [CoroutineContext],
+ * [Context.asCoroutineContext] puts Reactor's [Context] elements into a [CoroutineContext],
  * which can be used to propagate the information about Reactor's [Context] through coroutines.
  *
- * This context element is implicitly propagated through subscriber's context by all Reactive integrations,
+ * This context element is implicitly propagated through subscribers' context by all Reactive integrations,
  * such as [mono], [flux], [Publisher.asFlow][asFlow], [Flow.asPublisher][asPublisher] and [Flow.asFlux][asFlux].
- * Functions that subscribe to the reactive stream
+ * Functions that subscribe to a reactive stream
  * (e.g. [Publisher.awaitFirst][kotlinx.coroutines.reactive.awaitFirst]), too, propagate [ReactorContext]
  * to the subscriber's [Context].
  **
@@ -52,6 +52,7 @@ import reactor.util.context.*
 @ExperimentalCoroutinesApi
 public class ReactorContext(public val context: Context) : AbstractCoroutineContextElement(ReactorContext) {
 
+    // `Context.of` is zero-cost if the argument is a `Context`
     public constructor(contextView: ContextView): this(Context.of(contextView))
 
     public companion object Key : CoroutineContext.Key<ReactorContext>
@@ -69,8 +70,8 @@ public fun ContextView.asCoroutineContext(): ReactorContext = ReactorContext(thi
  * and later used via `coroutineContext[ReactorContext]`.
  */
 @ExperimentalCoroutinesApi
-@Deprecated("Use the more general version for ContextView instead", level = DeprecationLevel.HIDDEN)
-public fun Context.asCoroutineContext(): ReactorContext = readOnly().asCoroutineContext()
+@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.
 
 /**
  * Updates the Reactor context in this [CoroutineContext], adding (or possibly replacing) some values.