CombineExt 1.1.0

Author: freak4pc

CombineExt.podspec

@@ -1,6 +1,6 @@
 Pod::Spec.new do |s|
     s.name         = "CombineExt"
-    s.version      = "1.0.0"
+    s.version      = "1.1.0"
     s.summary      = "Combine operators and helpers not provided by Apple, and inspired by other Reactive Frameworks"
     s.description  = <<-DESC
       A collection of operators for Combine adding capabilities and utilities not provided by Apple,

Sources/Operators/Amb.swift

@@ -26,8 +26,7 @@ public extension Publisher {
     /// - returns: A publisher which mirrors the first publisher to emit an event
     func amb<Other: Publisher>(with others: Other...)
         -> AnyPublisher<Self.Output, Self.Failure> where Other.Output == Output, Other.Failure == Failure {
-        let never = Empty<Output, Failure>(completeImmediately: false).eraseToAnyPublisher()
-        return others.reduce(never) { result, current in
+        others.reduce(self.eraseToAnyPublisher()) { result, current in
             result.amb(current).eraseToAnyPublisher()
         }
     }

Tests/AmbTests.swift

@@ -139,8 +139,8 @@ class AmbTests: XCTestCase {
         var valuesThree = [Int]()
         var valuesFour = [Int]()
 
-        subject1
-            .amb(with: subject2, subject3, subject4)
+        subject4
+            .amb(with: subject2, subject3, subject1)
             .sink(receiveCompletion: { completionFour = $0 },
                   receiveValue: { valuesFour.append($0) })
             .store(in: &subscriptions)