Ensure that calling cancel() deallocates the subscription (#11)

teufelaudio · Mar 28, 2022 · 5bc3dbc · 5bc3dbc
1 parent fe8ee35
commit 5bc3dbc
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/Sources/CombineLongPolling/LongPollingPublisher.swift b/Sources/CombineLongPolling/LongPollingPublisher.swift
@@ -76,6 +76,8 @@ extension LongPollingPublisher {
             lock.lock()
             finished = true
             lock.unlock()
+            // Make sure to not wait for the semaphore, otherwise the object won't get allocated
+            semaphore.signal()
 
             buffer?.complete(completion: .finished)
             currentRequest = nil