diff --git a/Sources/Pwomise/Extensions/Publisher+Promise.swift b/Sources/Pwomise/Extensions/Publisher+Promise.swift index efea494..e38db50 100644 --- a/Sources/Pwomise/Extensions/Publisher+Promise.swift +++ b/Sources/Pwomise/Extensions/Publisher+Promise.swift @@ -18,16 +18,22 @@ public extension Publisher { var promise: Promise { let promise = Promise() - sink(receiveCompletion: { + var cancellable: AnyCancellable? + + cancellable = sink(receiveCompletion: { switch $0 { case .failure(let err): promise.result = .resolved(.failure(err)) + cancellable?.cancel() + cancellable = nil default: break } }, receiveValue: { value in promise.result = .resolved(.success(value)) - }).store(in: &cancellables) + cancellable?.cancel() + cancellable = nil + }) return promise }