RUM-3574 Start sending batches immediately after feature is initialized

DataDog · Apr 25, 2024 · 25e7c0c · 25e7c0c
1 parent 79943d3
commit 25e7c0c
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/DatadogCore/Sources/Core/Upload/DataUploadDelay.swift b/DatadogCore/Sources/Core/Upload/DataUploadDelay.swift
@@ -13,6 +13,7 @@ internal class DataUploadDelay {
     private let maxDelay: TimeInterval
     private let changeRate: Double
 
+    @ReadWriteLock
     private(set) var current: TimeInterval
 
     init(performance: UploadPerformancePreset) {

diff --git a/DatadogCore/Sources/Core/Upload/DataUploadWorker.swift b/DatadogCore/Sources/Core/Upload/DataUploadWorker.swift
@@ -66,8 +66,7 @@ internal class DataUploadWorker: DataUploadWorkerType {
         self.maxBatchesPerUpload = maxBatchesPerUpload
         self.featureName = featureName
         self.telemetry = telemetry
-
-        self.readWork = DispatchWorkItem { [weak self] in
+        let readWorkItem = DispatchWorkItem { [weak self] in
             guard let self = self else {
                 return
             }
@@ -87,7 +86,10 @@ internal class DataUploadWorker: DataUploadWorkerType {
                 self.scheduleNextCycle()
             }
         }
-        scheduleNextCycle()
+        self.readWork = readWorkItem
+
+        // Start sending batches immediately after initialization:
+        queue.async(execute: readWorkItem)
     }
 
     private func scheduleNextCycle() {