1. Fix issue #4, won't dispatch any coroutines with EmptyScope.

Author: bennyhuo

MainScope/src/main/java/com/bennyhuo/kotlin/coroutines/android/mainscope/MainScope.kt

@@ -4,6 +4,7 @@ import android.app.Application
 import com.bennyhuo.kotlin.coroutines.android.mainscope.internal.ActivityLifecycleCallbackImpl
 import com.bennyhuo.kotlin.coroutines.android.mainscope.job.EmptyInterceptor
 import com.bennyhuo.kotlin.coroutines.android.mainscope.job.EmptyJob
+import com.bennyhuo.kotlin.coroutines.android.mainscope.job.ImmutableCoroutineContext
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.SupervisorJob
@@ -25,5 +26,5 @@ internal class MainScopeImpl: MainScope {
 }
 
 internal object EmptyScope : MainScope {
- override val coroutineContext: CoroutineContext = EmptyJob() + EmptyInterceptor
+ override val coroutineContext: CoroutineContext = ImmutableCoroutineContext(EmptyJob() + EmptyInterceptor)
 }

MainScope/src/main/java/com/bennyhuo/kotlin/coroutines/android/mainscope/job/ImmutableCoroutineContext.kt

@@ -0,0 +1,15 @@
+package com.bennyhuo.kotlin.coroutines.android.mainscope.job
+
+import kotlin.coroutines.CoroutineContext
+import kotlin.coroutines.CoroutineContext.Element
+import kotlin.coroutines.CoroutineContext.Key
+
+class ImmutableCoroutineContext(private val coroutineContext: CoroutineContext): CoroutineContext {
+ override fun <R> fold(initial: R, operation: (R, Element) -> R): R = coroutineContext.fold(initial, operation)
+
+ override fun <E : Element> get(key: Key<E>) = coroutineContext[key]
+
+ override fun minusKey(key: Key<*>) = this
+
+ override fun plus(context: CoroutineContext) = this
+}

MainScope/src/main/java/com/bennyhuo/kotlin/coroutines/android/mainscope/job/JobCompat.java

@@ -11,6 +11,8 @@ abstract class JobCompat implements Job {
  @NotNull
  @Override
  public final ChildHandle attachChild(@NotNull ChildJob childJob) {
+ //Parent is already cancelled. So cancel child directly.
+ childJob.cancel(getCancellationException());
  return EmptyChildHandle.instance;
  }
 

app/src/main/java/com/bennyhuo/kotlin/coroutines/android/sample/MainActivity.kt

@@ -12,6 +12,8 @@ import com.bennyhuo.kotlin.coroutines.android.mainscope.RecyclerViewScoped
 import com.bennyhuo.kotlin.coroutines.android.mainscope.internal.withMainScope
 import kotlinx.android.synthetic.main.activity_main.*
 import kotlinx.coroutines.*
+import kotlinx.coroutines.CoroutineStart.ATOMIC
+import kotlinx.coroutines.CoroutineStart.UNDISPATCHED
 
 class MainActivity : AppCompatActivity(), AppCompatScoped, RecyclerViewScoped, DesignScoped {
 
@@ -67,10 +69,34 @@ class MainActivity : AppCompatActivity(), AppCompatScoped, RecyclerViewScoped, D
  withMainScope {
  launch {
  val job = coroutineContext[Job]
- log("This may be dispatched according to the start mode. isActive: ${job?.isActive}, isCancelled: ${job?.isCancelled}")
+ log("This may be dispatched according to the start mode: DEFAULT. isActive: ${job?.isActive}, isCancelled: ${job?.isCancelled}")
  //Scope is cancelled, so any cancellable suspend functions will respond to it.
  delay(100)
- log("Never gonna happen.")
+ log("[DEFAULT][Empty]Never gonna happen.")
+ }
+
+ launch(start = ATOMIC) {
+ val job = coroutineContext[Job]
+ log("This may be dispatched according to the start mode: ATOMIC. isActive: ${job?.isActive}, isCancelled: ${job?.isCancelled}")
+ //Scope is cancelled, so any cancellable suspend functions will respond to it.
+ delay(100)
+ log("[ATOMIC][DEFAULT]Never gonna happen.")
+ }
+
+ launch(start = UNDISPATCHED) {
+ val job = coroutineContext[Job]
+ log("This may be dispatched according to the start mode: UNDISPATCHED. isActive: ${job?.isActive}, isCancelled: ${job?.isCancelled}")
+ //Scope is cancelled, so any cancellable suspend functions will respond to it.
+ delay(100)
+ log("[UNDISPATCHED][DEFAULT]Never gonna happen.")
+ }
+
+ launch(Dispatchers.Default) {
+ val job = coroutineContext[Job]
+ log("This may be dispatched according to the start mode: DEFAULT, using Dispatcher: Default. isActive: ${job?.isActive}, isCancelled: ${job?.isCancelled}")
+ //Scope is cancelled, so any cancellable suspend functions will respond to it.
+ delay(100)
+ log("[DEFAULT][DEFAULT]Never gonna happen.")
  }
  }
  }