File tree Expand file tree Collapse file tree 4 files changed +4
-3
lines changed Expand file tree Collapse file tree 4 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -18,6 +18,7 @@ internal expect class SafeCollector<T>(
1818 internal val collectContext: CoroutineContext
1919 internal val collectContextSize: Int
2020 public fun releaseIntercepted ()
21+ public override suspend fun emit (value : T )
2122}
2223
2324@JvmName(" checkContext" ) // For prettier stack traces
Original file line number Diff line number Diff line change @@ -17,7 +17,7 @@ internal actual class SafeCollector<T> actual constructor(
1717 internal actual val collectContextSize = collectContext.fold(0 ) { count, _ -> count + 1 }
1818 private var lastEmissionContext: CoroutineContext ? = null
1919
20- override suspend fun emit (value : T ) {
20+ actual override suspend fun emit (value : T ) {
2121 val currentContext = currentCoroutineContext()
2222 currentContext.ensureActive()
2323 if (lastEmissionContext != = currentContext) {
Original file line number Diff line number Diff line change @@ -60,7 +60,7 @@ internal actual class SafeCollector<T> actual constructor(
6060 * then just cache an instance of the completion in order to avoid extra allocation on each emit,
6161 * making it effectively garbage-free on its hot-path.
6262 */
63- override suspend fun emit (value : T ) {
63+ actual override suspend fun emit (value : T ) {
6464 return suspendCoroutineUninterceptedOrReturn sc@{ uCont ->
6565 try {
6666 emit(uCont, value)
Original file line number Diff line number Diff line change @@ -17,7 +17,7 @@ internal actual class SafeCollector<T> actual constructor(
1717 internal actual val collectContextSize = collectContext.fold(0 ) { count, _ -> count + 1 }
1818 private var lastEmissionContext: CoroutineContext ? = null
1919
20- override suspend fun emit (value : T ) {
20+ actual override suspend fun emit (value : T ) {
2121 val currentContext = currentCoroutineContext()
2222 currentContext.ensureActive()
2323 if (lastEmissionContext != = currentContext) {
You can’t perform that action at this time.
0 commit comments