Appending current coroutineContext to make sure running/pending jobs …

…cancelled

when atomicCoroutineScope.cancel is called

chat-android/src/main/java/com/ably/chat/AtomicCoroutineScope.kt

@@ -2,9 +2,11 @@ package com.ably.chat
 
 import java.util.concurrent.PriorityBlockingQueue
 import kotlin.coroutines.cancellation.CancellationException
+import kotlin.coroutines.coroutineContext
 import kotlinx.coroutines.CompletableDeferred
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.cancel
 import kotlinx.coroutines.cancelChildren
 import kotlinx.coroutines.launch
 
@@ -66,7 +68,8 @@ class AtomicCoroutineScope(private val scope: CoroutineScope = CoroutineScope(Di
 
     private suspend fun <T : Any> safeExecute(job: Job<T>) {
         try {
-            scope.launch {
+            // Appends coroutineContext to cancel current/pending jobs when AtomicCoroutineScope is cancelled
+            scope.launch(coroutineContext) {
                 try {
                     val result = job.coroutineBlock(this)
                     job.deferredResult.complete(result)
@@ -81,6 +84,7 @@ class AtomicCoroutineScope(private val scope: CoroutineScope = CoroutineScope(Di
 
     /**
      * Cancels ongoing and pending operations with given error.
+     * See [Coroutine cancellation](https://kt.academy/article/cc-cancellation#cancellation-in-a-coroutine-scope) for more information.
      */
     @Synchronized
     fun cancel(message: String?, cause: Throwable? = null) {