RBusarow

import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.test.TestCoroutineDispatcher
import kotlinx.coroutines.test.TestCoroutineScope
import kotlinx.coroutines.test.resetMain
import kotlinx.coroutines.test.setMain
import org.junit.jupiter.api.extension.AfterAllCallback
import org.junit.jupiter.api.extension.AfterEachCallback
import org.junit.jupiter.api.extension.BeforeAllCallback
import org.junit.jupiter.api.extension.ExtendWith
import org.junit.jupiter.api.extension.ExtensionContext

RBusarow

@Qualifier  
annotation class MainCoroutineScope  
  
@Module  
object CoroutineScopeModule {  
  
  @Provides  
  @MainCoroutineScope  
  fun provideMainCoroutineScope(): CoroutineScope = CoroutineScope(Job() + Dispatchers.Main)
  

RBusarow

@Module  
object CoroutineScopeModule {  

  @Provides  
  fun provideDefaultCoroutineScope(): DefaultCoroutineScope = DefaultCoroutineScope()  
  
  @Provides  
  fun provideIOCoroutineScope(): IOCoroutineScope = IOCoroutineScope()  
  
  @Provides  

RBusarow

@Suppress("UNCHECKED_CAST")
class MutableLiveData2<T>(value: T) : LiveData<T>(value) {

  override fun getValue(): T = super.getValue() as T
  public override fun setValue(value: T) = super.setValue(value)
  public override fun postValue(value: T) = super.postValue(value)
}

RBusarow

import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.channels.BroadcastChannel
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.sync.Mutex
import kotlinx.coroutines.sync.withLock

fun <T> Flow<T>.shareIn(
        scope: CoroutineScope
): Flow<T> = SharedFlow(
        BroadcastManager(

RBusarow

class CoroutineTestRule : TestRule,  
                          TestPolymorphicCoroutineScope by TestPolymorphicCoroutineScope() { 

  val dispatcher = coroutineContext[ContinuationInterceptor] as TestCoroutineDispatcher  
    
  override fun apply(  
    base: Statement, description: Description?  
  ) = object : Statement() {  
    override fun evaluate() {  
      @Throws(Throwable::class)  

RBusarow

@ExperimentalCoroutinesApi  
interface TestPolymorphicCoroutineScope : TestCoroutineScope,  
  DefaultCoroutineScope,  
  IOCoroutineScope,  
  MainCoroutineScope,  
  MainImmediateCoroutineScope,  
  UnconfinedCoroutineScope
  
@ExperimentalCoroutinesApi  
private class TestPolymorphicCoroutineScopeImpl(

RBusarow

val scope = MainCoroutineScope()
val progressIndicator = ProgressIndicator(scope)

RBusarow

@Module  
object CoroutineScopeModule {  
  
  @Provides  
  fun provideMainCoroutineScope(): MainCoroutineScope = MainCoroutineScope()  
}

RBusarow

public fun MainCoroutineScope(  
  job: Job = SupervisorJob()  
): MainCoroutineScope = object : MainCoroutineScope {  
  override val coroutineContext = job + Dispatchers.Main  
}  
  
public fun MainCoroutineScope(  
  context: CoroutineContext  
): MainCoroutineScope = object : MainCoroutineScope {  
  override val coroutineContext = context + Dispatchers.Main