RBusarow

import kotlinx.coroutines.flow.*

/**
 * A "replay" flow which will record the last [size] collected values.
 *
 * When a collector begins collecting after values have already been recorded,
 * those values will be collected *before* values from the [sourceFlow] are collected.
 *
 * example:
 * ```

RBusarow

import kotlinx.coroutines.*
import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.channels.ProducerScope
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.sync.Mutex
import kotlinx.coroutines.sync.withLock

@FlowPreview
@ExperimentalCoroutinesApi

RBusarow

data class CoroutineContext(
  val job: Job? = null, 
  val interceptor: ContinuationInterceptor? = null, 
  val exceptionHandler: CoroutineExceptionHandler? = null, 
  val coroutineName: CoroutineName? = null
)

RBusarow

class SomeClass : CoroutineScope {

  val jobA = Job()
  
  override val coroutineContext: CoroutineContext
    get() = jobA + Dispatchers.Main
    
  fun doSomething() {
  
    // create a new coroutine using jobA and Main dispatcher

RBusarow

fun lookForCoroutineContextElements(context: CoroutineContext) {
  val job: CoroutineContext? = context[Job]
  val interceptor: CoroutineContext? = context[ContinuationInterceptor]
  val exceptionHandler: CoroutineContext? = context[CoroutineExceptionHandler]
  val name: CoroutineContext? = context[CoroutineName]
}

RBusarow

fun lookForCoroutineContextElements(context: CoroutineContext) {
  val job: Job? = context[Job]
  val interceptor: ContinuationInterceptor? = context[ContinuationInterceptor]
  val exceptionHandler: CoroutineExceptionHandler? = context[CoroutineExceptionHandler]
  val name: CoroutineName? = context[CoroutineName]
}

RBusarow

interface CoroutineScope {
  val coroutineContext: CoroutineContext
}

RBusarow

class SomeCoroutineScopeClass : CoroutineScope {
  override val coroutineContext: CoroutineContext

  init {
    val receiver: CoroutineContext = Job()
    val other: CoroutineContext = Dispatchers.Main
    
    // combine two contexts to create an entirely new instance
    val newContext: CoroutineContext = receiver + other
    

RBusarow

class SomeCoroutineScopeClass : CoroutineScope {
  override val coroutineContext = Job() + Dispatchers.Main
}

RBusarow

 class CoroutineContext {
   internal val map = mutableMapOf<Key<*>, Element>()

   operator fun <E : Element> get(key: Key<E>): E? = map[key] as? E

   interface Key<E : Element>
   interface Element
 }