diff options
Diffstat (limited to 'src/test/scala/scala/async/run/futures/FutureSpec.scala')
-rw-r--r-- | src/test/scala/scala/async/run/futures/FutureSpec.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/test/scala/scala/async/run/futures/FutureSpec.scala b/src/test/scala/scala/async/run/futures/FutureSpec.scala index eb57ff5..82e43fa 100644 --- a/src/test/scala/scala/async/run/futures/FutureSpec.scala +++ b/src/test/scala/scala/async/run/futures/FutureSpec.scala @@ -61,14 +61,14 @@ class FutureSpec { } f2 foreach { _ => throw new ThrowableTest("dispatcher foreach") } - f2 onSuccess { case _ => throw new ThrowableTest("dispatcher receive") } + f2 onComplete { case Success(_) => throw new ThrowableTest("dispatcher receive") } latch.open() Await.result(f2, defaultTimeout) mustBe ("success") f2 foreach { _ => throw new ThrowableTest("current thread foreach") } - f2 onSuccess { case _ => throw new ThrowableTest("current thread receive") } + f2 onComplete { case Success(_) => throw new ThrowableTest("current thread receive") } Await.result(f3, defaultTimeout) mustBe ("SUCCESS") @@ -251,7 +251,7 @@ class FutureSpec { val result = Future.find[Int](futures)(_ == 3) Await.result(result, defaultTimeout) mustBe (Some(3)) - val notFound = Future.find[Int](futures.iterator)(_ == 11) + val notFound = Future.find[Int](futures)(_ == 11) Await.result(notFound, defaultTimeout) mustBe (None) } |