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 25e08d4 commit fe64780Copy full SHA for fe64780
kotlinx-coroutines-core/common/src/flow/internal/AbstractSharedFlow.kt
@@ -82,7 +82,11 @@ internal abstract class AbstractSharedFlow<S : AbstractSharedFlowSlot<*>> : Sync
82
if (nCollectors == 0) nextIndex = 0
83
(slot as AbstractSharedFlowSlot<Any>).freeLocked(this)
84
}
85
- // Resume suspended coroutines
+ /*
86
+ Resume suspended coroutines.
87
+ This can happens when the subscriber that was freed was a slow one and was holding up buffer.
88
+ When this subscriber was freed, previously queued emitted can now wake up and are resumed here.
89
+ */
90
for (cont in resumes) cont?.resume(Unit)
91
// decrement subscription count
92
subscriptionCount?.increment(-1)
0 commit comments