aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/common/utils/FutureUtils.scala
diff options
context:
space:
mode:
authorvlad <vlad@driver.xyz>2017-06-13 10:25:55 -0700
committervlad <vlad@driver.xyz>2017-06-13 10:25:55 -0700
commit0000a65ab4479a2a40e2d6468036438e9705b4aa (patch)
tree60c868828741e7e5367aa7b6d167abbdaf91d5b8 /src/main/scala/xyz/driver/common/utils/FutureUtils.scala
downloadrest-query-0000a65ab4479a2a40e2d6468036438e9705b4aa.tar.gz
rest-query-0000a65ab4479a2a40e2d6468036438e9705b4aa.tar.bz2
rest-query-0000a65ab4479a2a40e2d6468036438e9705b4aa.zip
Initial extraction of Driver non-specific utilities
Diffstat (limited to 'src/main/scala/xyz/driver/common/utils/FutureUtils.scala')
-rw-r--r--src/main/scala/xyz/driver/common/utils/FutureUtils.scala19
1 files changed, 19 insertions, 0 deletions
diff --git a/src/main/scala/xyz/driver/common/utils/FutureUtils.scala b/src/main/scala/xyz/driver/common/utils/FutureUtils.scala
new file mode 100644
index 0000000..6933c63
--- /dev/null
+++ b/src/main/scala/xyz/driver/common/utils/FutureUtils.scala
@@ -0,0 +1,19 @@
+package xyz.driver.common.utils
+
+import scala.concurrent.{ExecutionContext, Future}
+import scala.util.Try
+
+object FutureUtils {
+
+ def executeSynchronously[T](f: ExecutionContext => Future[T]): Try[T] = {
+ val future = f {
+ new ExecutionContext {
+ override def reportFailure(cause: Throwable): Unit = cause.printStackTrace()
+
+ override def execute(runnable: Runnable): Unit = runnable.run()
+ }
+ }
+ future.value.get
+ }
+
+}