diff --git a/Sources/AsyncAlgorithms/AsyncChannel.swift b/Sources/AsyncAlgorithms/AsyncChannel.swift index f6d132f4..a9922a90 100644 --- a/Sources/AsyncAlgorithms/AsyncChannel.swift +++ b/Sources/AsyncAlgorithms/AsyncChannel.swift @@ -13,10 +13,10 @@ /// /// The `AsyncChannel` class is intended to be used as a communication type between tasks, /// particularly when one task produces values and another task consumes those values. The back -/// pressure applied by `send(_:)` and `finish()` via the suspension/resume ensure that -/// the production of values does not exceed the consumption of values from iteration. Each of these -/// methods suspends after enqueuing the event and is resumed when the next call to `next()` -/// on the `Iterator` is made. +/// pressure applied by `send(_:)` and `finish()` via the suspension/resume ensures that +/// the production of values does not exceed the consumption of values from iteration. Each of these +/// methods suspends after enqueuing the event and is resumed when the next call to `next()` +/// on the `Iterator` is made. public final class AsyncChannel: AsyncSequence, Sendable { /// The iterator for a `AsyncChannel` instance. public struct Iterator: AsyncIteratorProtocol, Sendable { diff --git a/Sources/AsyncAlgorithms/AsyncChunkedByGroupSequence.swift b/Sources/AsyncAlgorithms/AsyncChunkedByGroupSequence.swift index 7a9e9a3c..98154625 100644 --- a/Sources/AsyncAlgorithms/AsyncChunkedByGroupSequence.swift +++ b/Sources/AsyncAlgorithms/AsyncChunkedByGroupSequence.swift @@ -37,6 +37,7 @@ extension AsyncSequence { /// error, `AsyncChunkedByGroupSequence` will rethrow that error immediately and discard /// any current group. /// +/// let numbers = [10, 20, 30, 10, 40, 40, 10, 20].async /// let chunks = numbers.chunked { $0 <= $1 } /// for await numberChunk in chunks { /// print(numberChunk)