aboutsummaryrefslogtreecommitdiff
path: root/tests/pending/run/future-flatmap-exec-count.scala
diff options
context:
space:
mode:
Diffstat (limited to 'tests/pending/run/future-flatmap-exec-count.scala')
-rw-r--r--tests/pending/run/future-flatmap-exec-count.scala61
1 files changed, 0 insertions, 61 deletions
diff --git a/tests/pending/run/future-flatmap-exec-count.scala b/tests/pending/run/future-flatmap-exec-count.scala
deleted file mode 100644
index 849beb6b1..000000000
--- a/tests/pending/run/future-flatmap-exec-count.scala
+++ /dev/null
@@ -1,61 +0,0 @@
-import scala.concurrent._
-import java.util.concurrent.atomic.AtomicInteger
-
-object Test {
- def main(args: Array[String]): Unit = {
- test()
- }
-
- def test() = {
- def await(f: Future[Any]) =
- Await.result(f, duration.Duration.Inf)
-
- val ec = new TestExecutionContext(ExecutionContext.Implicits.global)
-
- {
- val p = Promise[Int]()
- val fp = p.future
- println("mapping")
- val mapped = fp.map(x => x)(ec)
- p.success(0)
- await(mapped)
- }
-
- {
- println("flatmapping")
- val p = Promise[Int]()
- val fp = p.future
- val flatMapped = fp.flatMap({ (x: Int) =>
- Future.successful(2 * x)
- })(ec)
- p.success(0)
- await(flatMapped)
- }
-
- {
- println("recovering")
- val recovered = Future.failed(new Throwable()).recoverWith {
- case _ => Future.successful(2)
- }(ec)
- await(recovered)
- }
- }
-
- class TestExecutionContext(delegate: ExecutionContext) extends ExecutionContext {
- def execute(runnable: Runnable): Unit = ???
-
- def reportFailure(t: Throwable): Unit = ???
-
- override def prepare(): ExecutionContext = {
- val preparedDelegate = delegate.prepare()
- return new ExecutionContext {
- def execute(runnable: Runnable): Unit = {
- println("execute()")
- preparedDelegate.execute(runnable)
- }
-
- def reportFailure(t: Throwable): Unit = ???
- }
- }
- }
-}