From 96d81a36286e41035ff4068859a3b0f9da924fbc Mon Sep 17 00:00:00 2001
From: vlad <vlad@driver.xyz>
Date: Fri, 30 Jun 2017 19:38:37 -0700
Subject: Latest PDS UI utils including all the domain stuff

---
 .../concurrent/SafeBridgeUploadQueue.scala         | 25 +++++++++++-----------
 1 file changed, 12 insertions(+), 13 deletions(-)

(limited to 'src/main/scala/xyz/driver/pdsuicommon/concurrent')

diff --git a/src/main/scala/xyz/driver/pdsuicommon/concurrent/SafeBridgeUploadQueue.scala b/src/main/scala/xyz/driver/pdsuicommon/concurrent/SafeBridgeUploadQueue.scala
index bab29d5..0bc8220 100644
--- a/src/main/scala/xyz/driver/pdsuicommon/concurrent/SafeBridgeUploadQueue.scala
+++ b/src/main/scala/xyz/driver/pdsuicommon/concurrent/SafeBridgeUploadQueue.scala
@@ -11,8 +11,7 @@ object SafeBridgeUploadQueue {
 
   trait Tag extends Product with Serializable
 
-  case class SafeTask[T <: Tag](tag: T,
-                                private[SafeBridgeUploadQueue] val queueItem: BridgeUploadQueue.Item)
+  case class SafeTask[T <: Tag](tag: T, private[SafeBridgeUploadQueue] val queueItem: BridgeUploadQueue.Item)
 
   object SafeTask {
     implicit def toPhiString[T <: Tag](x: SafeTask[T]): PhiString = {
@@ -27,20 +26,20 @@ object SafeBridgeUploadQueue {
 
 }
 
-class SafeBridgeUploadQueue[T <: Tag](kind: String,
-                                      origQueue: BridgeUploadQueue)
-                                     (implicit
-                                      tagMarshaller: Marshaller[T, String],
-                                      dependencyResolver: DependencyResolver[T],
-                                      executionContext: ExecutionContext) {
+class SafeBridgeUploadQueue[T <: Tag](kind: String, origQueue: BridgeUploadQueue)(
+        implicit tagMarshaller: Marshaller[T, String],
+        dependencyResolver: DependencyResolver[T],
+        executionContext: ExecutionContext) {
 
   type Task = SafeTask[T]
 
-  def add(tag: T): Future[BridgeUploadQueue.Item] = origQueue.add(BridgeUploadQueue.Item(
-    kind = kind,
-    tag = tagMarshaller.write(tag),
-    dependency = dependencyResolver.getDependency(tag)
-  ))
+  def add(tag: T): Future[BridgeUploadQueue.Item] =
+    origQueue.add(
+      BridgeUploadQueue.Item(
+        kind = kind,
+        tag = tagMarshaller.write(tag),
+        dependency = dependencyResolver.getDependency(tag)
+      ))
 
   def tryRetry(task: Task): Future[Option[Task]] = wrap(origQueue.tryRetry(task.queueItem))
 
-- 
cgit v1.2.3