We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c64597c commit ff489ddCopy full SHA for ff489dd
kotlinx-coroutines-core/common/src/flow/SharedFlow.kt
@@ -519,9 +519,9 @@ internal open class SharedFlowImpl<T>(
519
}
520
521
private fun cancelEmitter(emitter: Emitter) = synchronized(this) {
522
- if (emitter.index < head) return // already skipped past this index
+ if (emitter.index < head) return@synchronized // already skipped past this index
523
val buffer = buffer!!
524
- if (buffer.getBufferAt(emitter.index) !== emitter) return // already resumed
+ if (buffer.getBufferAt(emitter.index) !== emitter) return@synchronized // already resumed
525
buffer.setBufferAt(emitter.index, NO_VALUE)
526
cleanupTailLocked()
527
0 commit comments