refactor: update coroutine dispatcher checks and improve code style settings

Author: hoc081098

.idea/codeStyles/Project.xml

@@ -1,17 +1,22 @@
 package com.hoc.flowmvi.core_ui
 
-import kotlin.coroutines.ContinuationInterceptor
+import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.currentCoroutineContext
 import timber.log.Timber
 
-suspend fun debugCheckImmediateMainDispatcher() {
+@OptIn(ExperimentalStdlibApi::class)
+suspend inline fun debugCheckImmediateMainDispatcher() {
   if (BuildConfig.DEBUG) {
-    val interceptor = currentCoroutineContext()[ContinuationInterceptor]
-    Timber.d("debugCheckImmediateMainDispatcher: interceptor=$interceptor")
+    val dispatcher = checkNotNull(currentCoroutineContext()[CoroutineDispatcher]) {
+      "Expected CoroutineDispatcher in current CoroutineContext but was null"
+    }.also { Timber.d("debugCheckImmediateMainDispatcher: dispatcher=$it") }
 
-    check(interceptor === Dispatchers.Main.immediate) {
-      "Expected ContinuationInterceptor to be Dispatchers.Main.immediate but was $interceptor"
+    check(
+      dispatcher === Dispatchers.Main.immediate ||
+        !dispatcher.isDispatchNeeded(Dispatchers.Main.immediate),
+    ) {
+      "Expected ContinuationInterceptor to be Dispatchers.Main.immediate but was $dispatcher"
     }
   }
 }

core-ui/src/main/java/com/hoc/flowmvi/core_ui/debugCheckImmediateMainDispatcher.kt

@@ -7,6 +7,7 @@ import androidx.lifecycle.viewModelScope
 import com.hoc.flowmvi.core_ui.debugCheckImmediateMainDispatcher
 import java.util.concurrent.atomic.AtomicInteger
 import kotlin.LazyThreadSafetyMode.PUBLICATION
+import kotlinx.coroutines.ExperimentalForInheritanceCoroutinesApi
 import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.channels.onFailure
 import kotlinx.coroutines.flow.Flow
@@ -36,7 +37,7 @@ abstract class AbstractMviViewModel<I : MviIntent, S : MviViewState, E : MviSing
   }
 
   private val eventChannel = Channel<E>(Channel.UNLIMITED)
-  private val intentMutableFlow = MutableSharedFlow<I>(extraBufferCapacity = SubscriberBufferSize)
+  private val intentMutableFlow = MutableSharedFlow<I>(extraBufferCapacity = SUBSCRIBER_BUFFER_SIZE)
 
   final override val singleEvent: Flow<E> = eventChannel.receiveAsFlow()
 
@@ -85,6 +86,8 @@ abstract class AbstractMviViewModel<I : MviIntent, S : MviViewState, E : MviSing
     if (BuildConfig.DEBUG) {
       val self = this
 
+      @Suppress("UnnecessaryOptInAnnotation")
+      @OptIn(ExperimentalForInheritanceCoroutinesApi::class)
       object : SharedFlow<T> by self {
         val subscriberCount = AtomicInteger(0)
 
@@ -125,7 +128,7 @@ abstract class AbstractMviViewModel<I : MviIntent, S : MviViewState, E : MviSing
      * The internally allocated buffer is replay + extraBufferCapacity but always allocates 2^n space.
      * We use replay=0 so buffer = 64.
      */
-    private const val SubscriberBufferSize = 64
+    private const val SUBSCRIBER_BUFFER_SIZE = 64
 
     private const val MAX_TAG_LENGTH = 23
   }