diff --git a/Sources/CombineLongPolling/LongPollingPublisher.swift b/Sources/CombineLongPolling/LongPollingPublisher.swift index 999607c..021cf7c 100644 --- 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