~improve doc

Author: qwwdfsad

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

@@ -18,8 +18,8 @@ import kotlin.internal.LowPriorityInOverloadResolution
 /**
  * Creates cold reactive [Publisher] that runs a 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`, [completes][Subscriber.onComplete]
- * when the coroutine completes or channel is explicitly closed and emits [error][Subscriber.onError]
+ * Coroutine emits ([Subscriber.onNext]) values with `send`, completes ([Subscriber.onComplete])
+ * when the coroutine completes or channel is explicitly closed and emits error ([Subscriber.onError])
  * if coroutine throws an exception or closes channel with a cause.
  * Unsubscribing cancels running coroutine.
  *

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

@@ -20,8 +20,8 @@ import kotlin.internal.*
 /**
  * Creates cold reactive [Flux] that runs a 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`, [completes][Subscriber.onComplete]
- * when the coroutine completes or channel is explicitly closed and emits [error][Subscriber.onError]
+ * Coroutine emits ([Subscriber.onNext]) values with `send`, completes ([Subscriber.onComplete])
+ * when the coroutine completes or channel is explicitly closed and emits error ([Subscriber.onError])
  * if coroutine throws an exception or closes channel with a cause.
  * Unsubscribing cancels running coroutine.
  *

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

@@ -15,7 +15,7 @@ import kotlin.internal.*
 /**
  * Creates cold [mono][Mono] that will run a given [block] in a coroutine and emits its result.
  * Every time the returned mono is subscribed, it starts a new coroutine.
- * If [block] result is `null`, [success][MonoSink.success] is invoked without a value.
+ * If [block] result is `null`, [MonoSink.success] is invoked without a value.
  * Unsubscribing cancels running coroutine.
  *
  * Coroutine context can be specified with [context] argument.

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

@@ -17,8 +17,8 @@ import kotlin.internal.*
  * Creates cold [flowable][Flowable] that will run a given [block] in a coroutine.
  * Every time the returned flowable is subscribed, it starts a new coroutine.
  *
- * Coroutine [emits][ObservableEmitter.onNext] values with `send`, [completes][ObservableEmitter.onComplete]
- * when the coroutine completes or channel is explicitly closed and emits [error][ObservableEmitter.onError]
+ * Coroutine emits ([ObservableEmitter.onNext]) values with `send`, completes ([ObservableEmitter.onComplete])
+ * when the coroutine completes or channel is explicitly closed and emits error ([ObservableEmitter.onError])
  * if coroutine throws an exception or closes channel with a cause.
  * Unsubscribing cancels running coroutine.
  *

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

@@ -20,8 +20,8 @@ import kotlin.internal.*
  * Creates cold [observable][Observable] that will run a given [block] in a coroutine.
  * Every time the returned observable is subscribed, it starts a new coroutine.
  *
- * Coroutine [emits][ObservableEmitter.onNext] values with `send`, [completes][ObservableEmitter.onComplete]
- * when the coroutine completes or channel is explicitly closed and emits [error][ObservableEmitter.onError]
+ * Coroutine emits ([ObservableEmitter.onNext]) values with `send`, completes ([ObservableEmitter.onComplete])
+ * when the coroutine completes or channel is explicitly closed and emits error ([ObservableEmitter.onError])
  * if coroutine throws an exception or closes channel with a cause.
  * Unsubscribing cancels running coroutine.
  *