raceN

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

fun main(args: Array<String>) {
  fun <F> Concurrent<F>.example(): Kind<F, String> {
    val never: Kind<F, Int> = cancellable { effect { println("Never got cancelled for losing.") } }

    //sampleStart
    val result = fx.concurrent {
      val eitherGetOrUnit = !Dispatchers.Default.raceN(never, just(5))
      eitherGetOrUnit.fold(
        { "Never always loses race" },
        { i -> "Race was won with $i" }
      )
    }
  //sampleEnd
  return result
  }

  IO.concurrent().example().fix().unsafeRunSync().let(::println)
}