blob: 7625c1b511f87bdae053ba3717983439371f97f5 [file] [log] [blame]
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/
package kotlinx.coroutines.experimental.internal
import kotlinx.coroutines.experimental.*
import kotlin.coroutines.experimental.*
/**
* This is a coroutine instance that is created by [coroutineScope] builder.
*/
internal open class ScopeCoroutine<in T>(
context: CoroutineContext,
@JvmField val uCont: Continuation<T> // unintercepted continuation
) : AbstractCoroutine<T>(context, true) {
override val defaultResumeMode: Int get() = MODE_DIRECT
@Suppress("UNCHECKED_CAST")
internal override fun onCompletionInternal(state: Any?, mode: Int, suppressed: Boolean) {
if (state is CompletedExceptionally)
uCont.resumeUninterceptedWithExceptionMode(state.cause, mode)
else
uCont.resumeUninterceptedMode(state as T, mode)
}
}
internal class ContextScope(context: CoroutineContext) : CoroutineScope {
override val coroutineContext: CoroutineContext = context
}