fork

import arrow.Kind
import arrow.fx.*
import arrow.fx.extensions.io.concurrent.concurrent
import arrow.fx.typeclasses.Concurrent
import kotlinx.coroutines.Dispatchers

fun main(args: Array<String>) {
  fun <F> Concurrent<F>.example(): Kind<F, Unit> =
  //sampleStart
    fx.concurrent {
      val (join, cancel) = !effect {
        println("Hello from a fiber on ${Thread.currentThread().name}")
      }.fork(Dispatchers.Default)
    }

  //sampleEnd
  IO.concurrent().example().fix().unsafeRunSync()
}