Skip to content

Commit 88b0966

Browse files
committed
Merge branch 'master' into develop
2 parents ba33cfc + 66fe1c8 commit 88b0966

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

kotlinx-coroutines-core/common/src/channels/Channel.kt

+2-2
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public interface SendChannel<in E> {
9090
/**
9191
* Closes this channel.
9292
* This is an idempotent operation &mdash; subsequent invocations of this function have no effect and return `false`.
93-
* Conceptually, its sends a special "close token" over this channel.
93+
* Conceptually, it sends a special "close token" over this channel.
9494
*
9595
* Immediately after invocation of this function,
9696
* [isClosedForSend] starts returning `true`. However, [isClosedForReceive][ReceiveChannel.isClosedForReceive]
@@ -498,7 +498,7 @@ public interface ChannelIterator<out E> {
498498
* * When `capacity` is [Channel.CONFLATED] &mdash; it creates a _conflated_ channel
499499
* This channel buffers at most one element and conflates all subsequent `send` and `offer` invocations,
500500
* so that the receiver always gets the last element sent.
501-
* Back-to-send sent elements are conflated &mdash; only the last sent element is received,
501+
* Back-to-back sent elements are conflated &mdash; only the last sent element is received,
502502
* while previously sent elements **are lost**.
503503
* [Sending][send] to this channel never suspends, and [offer] always returns `true`.
504504
*

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -181,7 +181,7 @@ public fun <T> Flow<T>.buffer(capacity: Int = BUFFERED): Flow<T> = buffer(capaci
181181
* **Conflation takes precedence over `buffer()` calls with any other capacity.**
182182
*
183183
* Note that any instance of [StateFlow] already behaves as if `conflate` operator is
184-
* applied to it, so applying `conflate` to a `StateFlow` has not effect.
184+
* applied to it, so applying `conflate` to a `StateFlow` has no effect.
185185
* See [StateFlow] documentation on Operator Fusion.
186186
*/
187187
public fun <T> Flow<T>.conflate(): Flow<T> = buffer(CONFLATED)

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public val DEFAULT_CONCURRENCY: Int = systemProp(DEFAULT_CONCURRENCY_PROPERTY_NA
3434
* Transforms elements emitted by the original flow by applying [transform], that returns another flow,
3535
* and then concatenating and flattening these flows.
3636
*
37-
* This method is is a shortcut for `map(transform).flattenConcat()`. See [flattenConcat].
37+
* This method is a shortcut for `map(transform).flattenConcat()`. See [flattenConcat].
3838
*
3939
* Note that even though this operator looks very familiar, we discourage its usage in a regular application-specific flows.
4040
* Most likely, suspending operation in [map] operator will be sufficient and linear transformations are much easier to reason about.

0 commit comments

Comments
 (0)