scala - 永远不会完成的 future

Question

需要测试一些可能导致超时的方法，我想为此创建一个辅助函数。它应该返回一个 Future那个从不 完成:

def neverCompletes[T]: Future[T] = { ... }

但我想知道，我该怎么做？我可以喜欢以下内容:

def neverCompletes[T]: Future[T] = {
  val p = Promise[T]()
  future {
    while(true) { }
  } onComplete {
    case x => 
      p complete x // needed?
      println("something went wrong!!!") // something is wrong...
  }

  p.future
}

但是应该有更好的方法来实现这一目标。我也不确定是否 p complete x // needed?那里需要。

Answer 1

更新:

在 Scala 2.12 中会有一个方法 Future.never返回一个永远不会完成的 future 。

容易的事。只需创建一个 Promise并返回其 Future没有完成它:

def neverCompletes[T]: Future[T] = Promise[T].future