Remove the mapping error util

Author: czechboy0

Sources/AsyncAlgorithms/CombineLatest/CombineLatestManyStateMachine.swift

@@ -11,8 +11,6 @@
 
 import DequeModule
 
-// TODO: Do we need to add Failure: Error generic here?
-
 /// State machine for combine latest
 @available(AsyncAlgorithms 1.1, *)
 struct CombineLatestManyStateMachine<Element: Sendable>: Sendable {

Tests/AsyncAlgorithmsTests/TestCombineLatestMany.swift

@@ -15,18 +15,18 @@ import AsyncAlgorithms
 @available(AsyncAlgorithms 1.1, *)
 final class TestCombineLatestMany: XCTestCase {
   func test_combineLatest() async throws {
-    let a = [1, 2, 3].async.mappedFailureToError
-    let b = [4, 5, 6].async.mappedFailureToError
-    let c = [7, 8, 9].async.mappedFailureToError
+    let a = [1, 2, 3].async
+    let b = [4, 5, 6].async
+    let c = [7, 8, 9].async
     let sequence = combineLatestMany([a, b, c])
     let actual = try await Array(sequence)
     XCTAssertGreaterThanOrEqual(actual.count, 3)
   }
 
   func test_ordering1() async {
-    var a = GatedSequence([1, 2, 3]).mappedFailureToError
-    var b = GatedSequence([4, 5, 6]).mappedFailureToError
-    var c = GatedSequence([7, 8, 9]).mappedFailureToError
+    var a = GatedSequence([1, 2, 3])
+    var b = GatedSequence([4, 5, 6])
+    var c = GatedSequence([7, 8, 9])
     let finished = expectation(description: "finished")
     let sequence = combineLatestMany([a, b, c])
     let validator = Validator<[Int]>()
@@ -83,24 +83,3 @@ final class TestCombineLatestMany: XCTestCase {
     )
   }
 }
-
-@available(AsyncAlgorithms 1.1, *)
-private struct MappingErrorAsyncSequence<Upstream: AsyncSequence & Sendable>: AsyncSequence, Sendable where Upstream.Failure == Never {
-    var upstream: Upstream
-    func makeAsyncIterator() -> Iterator {
-        Iterator(upstream: upstream.makeAsyncIterator())
-    }
-    struct Iterator: AsyncIteratorProtocol {
-        var upstream: Upstream.AsyncIterator
-        mutating func next(isolation actor: isolated (any Actor)?) async throws -> Upstream.Element? {
-            await upstream.next(isolation: actor)
-        }
-    }
-}
-
-@available(AsyncAlgorithms 1.1, *)
-extension AsyncSequence where Failure == Never, Self: Sendable {
-    var mappedFailureToError: some AsyncSequence<Element, any Error> & Sendable {
-        MappingErrorAsyncSequence(upstream: self)
-    }
-}