#3 Using Await.result to block instead of runSyncMaybe.

profunktor · Jun 17, 2017 · afd403d · afd403d
1 parent 7f48bd7
commit afd403d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/.../src/main/scala/com/github/gvolpe/fs2rabbit/examples/scheduler/MonixEffectScheduler.scala b/.../src/main/scala/com/github/gvolpe/fs2rabbit/examples/scheduler/MonixEffectScheduler.scala
@@ -5,8 +5,8 @@ import fs2.Scheduler
 import monix.eval.Task
 import monix.execution.Scheduler.Implicits.global
 
-import scala.concurrent.ExecutionContext
-import scala.concurrent.duration._
+import scala.concurrent.{Await, ExecutionContext}
+import scala.concurrent.duration.{Duration, FiniteDuration}
 
 object MonixEffectScheduler extends EffectScheduler[Task] {
 
@@ -16,6 +16,6 @@ object MonixEffectScheduler extends EffectScheduler[Task] {
   }
 
   override def unsafeRunSync(effect: Task[Unit]) = {
-    effect.runSyncMaybe
+    Await.result(effect.runAsync, Duration.Inf)
   }
 }