Add overrides to support Infallible

Sources/Rx+Combine/Infallible+Combine.swift

@@ -0,0 +1,44 @@
+//
+//  Infallible+Combine.swift
+//  RxCombine
+
+#if canImport(Combine)
+import Combine
+import RxSwift
+
+@available(OSX 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
+public extension Infallible {
+    /// An `AnyPublisher` of the underlying Observable's Element type
+    /// so the Infallible pushes events to the Publisher.
+    var publisher: AnyPublisher<Element, Swift.Never> {
+        RxInfalliblePublisher(upstream: self).eraseToAnyPublisher()
+    }
+
+    /// Returns a `AnyPublisher` of the underlying Observable's Element type
+    /// so the Infallible pushes events to the Publisher.
+    ///
+    /// - returns: AnyPublisher of the underlying Observable's Element type.
+    /// - note: This is an alias for the `publisher` property.
+    func asPublisher() -> AnyPublisher<Element, Swift.Never> {
+        publisher
+    }
+}
+
+/// A Publisher of failure type Never pushing RxSwift events to a Downstream Combine subscriber.
+@available(OSX 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
+public class RxInfalliblePublisher<Upstream: ObservableConvertibleType>: Publisher {
+    public typealias Output = Upstream.Element
+    public typealias Failure = Swift.Never
+
+    private let upstream: Upstream
+
+    init(upstream: Upstream) {
+        self.upstream = upstream
+    }
+
+    public func receive<S: Subscriber>(subscriber: S) where Failure == S.Failure, Output == S.Input {
+        subscriber.receive(subscription: RxInfallibleSubscription(upstream: upstream,
+                                                        downstream: subscriber))
+    }
+}
+#endif

Tests/ObservableAsPublisherTests.swift

@@ -86,6 +86,21 @@ class ObservableAsPublisherTests: XCTestCase {
         XCTAssertEqual(values, Array(1...10))
         XCTAssertTrue(completed)
     }
+
+    func testStringInfallible() {
+        let input = "Hello world I'm a RxSwift Infallible".components(separatedBy: " ")
+        let source = Infallible.from(input)
+        var values = [String]()
+        var completed = false
+
+        subscription = source
+            .asPublisher()
+            .handleEvents(receiveCompletion: { _ in completed = true })
+            .sink(receiveValue: { values.append($0) }) // this syntax is only allowed when Failure == Never
+
+        XCTAssertEqual(values, input)
+        XCTAssertTrue(completed)
+    }
 }
 
 enum FakeError: Swift.Error {