import scala.concurrent.{Await, ExecutionContext, Future, Promise}
import cats.implicits._

import scala.concurrent.duration.Duration
import scala.util.{Failure, Success}

final case class FutureConcurrentEffect()(implicit ec: ExecutionContext) extends FutureEffect with ConcurrentEffect[Future] {
  def start[A](fa: Future[A]): Future[Fiber[Future, A]] = Future.successful {
    FutureFiber(fa)
  }

  def racePair[A, B](fa: Future[A], fb: Future[B]): Future[Either[(A, Fiber[Future, B]), (Fiber[Future, A], B)]] = ???

  def runCancelable[A](fa: Future[A])(cb: Either[Throwable, A] => IO[Unit]): SyncIO[CancelToken[Future]] = ???
}