[lib] Perform delete operations in parallel (#223)

2019-10-03 12:01:05 +01:00 · 2019-10-03 12:01:05 +01:00 · 86a22215cd
commit 86a22215cd
parent 61231b8e97
1 changed files with 4 additions and 1 deletions
--- a/lib/src/main/scala/net/kemitix/thorp/lib/LocalFileSystem.scala
+++ b/lib/src/main/scala/net/kemitix/thorp/lib/LocalFileSystem.scala
@ -78,7 +78,10 @@ object LocalFileSystem extends LocalFileSystem {
                                 actionCounter,
                                 bytesCounter,
                                 eventsRef)
-      _      <- MessageChannel.pointToPoint(keySender)(keyReceiver).runDrain
+      parallel <- Config.parallel
+      _ <- MessageChannel
+        .pointToPointPar(parallel)(keySender)(keyReceiver)
+        .runDrain
      events <- eventsRef.get
    } yield events