Future to Task

TaskUtils.scala

def toTask[T](ft: => Future[T]): Task[T] = {  
  import scalaz._ 
  import scalaz.Scalaz._     
  Task.async { register =>      
    ft.onComplete({
      case scala.util.Success(v) => register(\/-(v))  
      case scala.util.Failure(ex) => register(-\/(ex))  
    })
  }
}