ExploreCoroutines_DispatchedTask.kt

internal abstract class DispatchedTask<in T>(
    @JvmField public var resumeMode: Int
) : SchedulerTask() {

   public final override fun run() {
     // ...
     try {
         val delegate = delegate as DispatchedContinuation<T>
         val continuation = delegate.continuation
         withContinuationContext(continuation, delegate.countOrElement) {
             // ...
             val job = if (exception == null && resumeMode.isCancellableMode) context[Job] else null
             if (job != null && !job.isActive) {
                 val cause = job.getCancellationException()
                 cancelCompletedResult(state, cause)
                 continuation.resumeWithStackTrace(cause)
             } else {
                 if (exception != null) {
                     continuation.resumeWithException(exception)
                 } else {
                     continuation.resume(getSuccessfulResult(state))
                 }
             }
         }
     }
     // ...
   }
}