Skip to content

Commit 22a7d8a

Browse files
ndkovalqwwdfsad
authored andcommitted
documentation
1 parent 1c043a1 commit 22a7d8a

File tree

4 files changed

+520
-478
lines changed

4 files changed

+520
-478
lines changed

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

+2-2
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ internal open class BroadcastChannelImpl<E>(
206206
override suspend fun send(element: E) {
207207
val subs = lock.withLock { // protected by lock
208208
// Is this channel closed for send?
209-
if (isClosedForSend) throw sendException(getCloseCause())
209+
if (isClosedForSend) throw sendException
210210
// Update the last sent element if this broadcast is conflated.
211211
if (capacity == CONFLATED) lastConflatedElement = element
212212
// Get a copy of subscriber list. Unfortunately,
@@ -226,7 +226,7 @@ internal open class BroadcastChannelImpl<E>(
226226
val success = it.sendBroadcast(element)
227227
// The sending attempt has failed.
228228
// Check whether the broadcast is closed.
229-
if (!success && isClosedForSend) throw sendException(getCloseCause())
229+
if (!success && isClosedForSend) throw sendException
230230
}
231231
}
232232

0 commit comments

Comments
 (0)