Fix thread-safety (#16)

FluidGroup · Jul 7, 2023 · 3ddc450 · 3ddc450
1 parent f1fecaf
commit 3ddc450
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/Sources/Bulk/Core/BulkSink.swift b/Sources/Bulk/Core/BulkSink.swift
@@ -30,13 +30,15 @@ public final class BulkSink<Element>: BulkSinkType {
 
       guard let self else { return }
 
-      let elements = buffer.purge()
-
-      self.targets.forEach {
-        $0.write(items: elements)
+      self.targetQueue.async { [self] in
+        let elements = buffer.purge()
+
+        self.targets.forEach {
+          $0.write(items: elements)
+        }
+
+        self.timer.tap()
       }
-
-      self.timer.tap()
     }
 
   }