Avoid last request after cancellation (#10)

teufelaudio · Jan 26, 2022 · 45cfd7d · 45cfd7d
1 parent 737b543
commit 45cfd7d
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/Sources/CombineLongPolling/LongPollingPublisher.swift b/Sources/CombineLongPolling/LongPollingPublisher.swift
@@ -102,6 +102,13 @@ extension LongPollingPublisher {
                 // on the first run, the semaphore is 1, so we are not blocked here and fetch the data immediately.
                 semaphore.wait()
 
+                lock.lock()
+                guard started && !finished else {
+                    lock.unlock()
+                    return
+                }
+                lock.unlock()
+
                 currentRequest = dataTaskPublisher
                     .catch { error -> AnyPublisher<(data: Data, response: URLResponse), URLError> in
                         // Timeout errors are accepted as valid. In Long Polling terms that means that there's no output during the