arrow-fx-coroutines/arrow.fx.coroutines/singleThreadContext

singleThreadContext

suspend fun ResourceScope.singleThreadContext(name: String): ERROR CLASS: Symbol not found for ExecutorCoroutineDispatcher

Creates a single threaded CoroutineContext as a Resource. Upon release an orderly shutdown of the ExecutorService takes place in which previously submitted tasks are executed, but no new tasks will be accepted.

import arrow.fx.coroutines.resourceScope
import arrow.fx.coroutines.singleThreadContext
import kotlinx.coroutines.withContext
import kotlinx.coroutines.ExecutorCoroutineDispatcher

suspend fun main(): Unit = resourceScope {
  val single: ExecutorCoroutineDispatcher = singleThreadContext("single")
  withContext(single) {
    println("I am running on ${Thread.currentThread().name}")
  }
}

I am running on single

fun singleThreadContext(name: String): Resource<ERROR CLASS: Symbol not found for ExecutorCoroutineDispatcher>