Invalidate publisher promise on first fire

EricRabil · Sep 11, 2021 · 5b6d3f3 · 5b6d3f3
1 parent 2b004b1
commit 5b6d3f3
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/Sources/Pwomise/Extensions/Publisher+Promise.swift b/Sources/Pwomise/Extensions/Publisher+Promise.swift
@@ -18,16 +18,22 @@ public extension Publisher {
  var promise: Promise<Output> {
  let promise = Promise<Output>()
 
- 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
  }