Timeout fs2 task

TaskWithTimeout.scala

import fs2.Task
import scala.concurrent.duration.FiniteDuration

object TaskWithTimeout {

  implicit class TaskWithTimeout[A](x: Task[A]) {
    
    /**
    * If the main task fails or times out, it returns the default value
    */
    def timeout(default: A, duration: FiniteDuration)(implicit S:fs2.Strategy, scheduler:fs2.Scheduler):Task[A] =
      fs2.Stream
        .eval(x.attempt) 
        .mergeHaltBoth(
          fs2.time.sleep_[Task](duration) ++ fs2.Stream.eval(Task.now(default)).attempt
        ).runLog.map(_.head.toOption.getOrElse(default))
    }

}