diff --git a/docs/topics/channels.md b/docs/topics/channels.md index 6820f4c93c..402fb5a170 100644 --- a/docs/topics/channels.md +++ b/docs/topics/channels.md @@ -364,7 +364,7 @@ fun CoroutineScope.launchProcessor(id: Int, channel: ReceiveChannel) = laun > {type="note"} -The output will be similar to the the following one, albeit the processor ids that receive +The output will be similar to the following one, albeit the processor ids that receive each specific integer may be different: ```text diff --git a/kotlinx-coroutines-core/common/src/flow/Migration.kt b/kotlinx-coroutines-core/common/src/flow/Migration.kt index ede671846c..45b8abc671 100644 --- a/kotlinx-coroutines-core/common/src/flow/Migration.kt +++ b/kotlinx-coroutines-core/common/src/flow/Migration.kt @@ -90,7 +90,7 @@ public fun Flow.publishOn(context: CoroutineContext): Flow = noImpl() * } * } * ``` - * Opposed to subscribeOn, it it **possible** to use multiple `flowOn` operators in the one flow + * Opposed to subscribeOn, it is **possible** to use multiple `flowOn` operators in the one flow * @suppress */ @Deprecated(message = "Use 'flowOn' instead", level = DeprecationLevel.ERROR) diff --git a/kotlinx-coroutines-core/common/src/flow/operators/Limit.kt b/kotlinx-coroutines-core/common/src/flow/operators/Limit.kt index d40a92d00b..dc3b709a5f 100644 --- a/kotlinx-coroutines-core/common/src/flow/operators/Limit.kt +++ b/kotlinx-coroutines-core/common/src/flow/operators/Limit.kt @@ -123,7 +123,7 @@ internal suspend inline fun Flow.collectWhile(crossinline predicate: susp val collector = object : FlowCollector { override suspend fun emit(value: T) { // Note: we are checking predicate first, then throw. If the predicate does suspend (calls emit, for example) - // the the resulting code is never tail-suspending and produces a state-machine + // the resulting code is never tail-suspending and produces a state-machine if (!predicate(value)) { throw AbortFlowException(this) }