~ Use CoroutineContext.cancel extension

elizarov · elizarov · commit 703b99a8c24d · 2020-05-12T21:50:58.000+03:00
diff --git a/kotlinx-coroutines-core/jvm/src/Executors.kt b/kotlinx-coroutines-core/jvm/src/Executors.kt
@@ -139,7 +139,7 @@ internal abstract class ExecutorCoroutineDispatcherBase : ExecutorCoroutineDispa
     }
 
     private fun cancelJobOnRejection(context: CoroutineContext, exception: RejectedExecutionException) {
-        context[Job]?.cancel(CancellationException("The task was rejected", exception))
+        context.cancel(CancellationException("The task was rejected", exception))
     }
 
     override fun close() {

Original file line number	Diff line number	Diff line change
`@@ -139,7 +139,7 @@ internal abstract class ExecutorCoroutineDispatcherBase : ExecutorCoroutineDispa`
`139`	`139`	`}`
`140`	`140`
`141`	`141`	`private fun cancelJobOnRejection(context: CoroutineContext, exception: RejectedExecutionException) {`
`142`		`- context[Job]?.cancel(CancellationException("The task was rejected", exception))`
	`142`	`+ context.cancel(CancellationException("The task was rejected", exception))`
`143`	`143`	`}`
`144`	`144`
`145`	`145`	`override fun close() {`