Combine框架中如何将Publisher的错误类型转换为Never

你无法直接将PassthroughSubject<Int, Error>的实例强制转换为PassthroughSubject<Int, Never>类型，二者属于完全不同的泛型类型。你可以通过以下两种方案满足需求：

方案1：手动绑定生成目标PassthroughSubject #

如果需要得到明确的PassthroughSubject<Int, Never>实例，你可以手动订阅原有Subject，把正常的值转发到新的无错误Subject，错误和完成事件根据你的需求处理：

import Combine

var cancellables = Set<AnyCancellable>()
// 原有带错误的Subject
var subject = PassthroughSubject<Int, Error>()
// 目标无错误的Subject
let neverSubject = PassthroughSubject<Int, Never>()

// 绑定两个Subject的事件
subject
    .sink(
        receiveCompletion: { completion in
            switch completion {
            case .finished:
                // 如果需要上游结束时同步结束下游就开启下面这行，否则直接忽略
                // neverSubject.send(completion: .finished)
                break
            case .failure(_):
                // 收到错误直接忽略，不向下游发送终止事件
                break
            }
        },
        receiveValue: { value in
            // 转发所有正常输出值
            neverSubject.send(value)
        }
    )
    .store(in: &cancellables)

该方案优势：

• 完全符合类型要求，最终得到的就是你需要的PassthroughSubject<Int, Never>实例
• 上游发送的错误不会触发下游Subject的终止，可灵活控制上下游的生命周期绑定逻辑

注意：如果原有Subject主动发送了.failure类型的completion，它自身会直接进入终止状态，后续所有send(_:)调用都会失效，这种情况无论用什么转换方法都无法继续接收新值，需要避免直接给该Subject发送错误completion。

方案2：转换为Failure为Never的Publisher #

如果你只需要一个输出为Int、失败类型为Never的流，不需要显式拿到PassthroughSubject实例，可以用flatMap嵌套catch的方式处理单个值的错误，避免整个流终止：

let neverPublisher = subject
    .flatMap { value in
        Just(value)
            // 这里可以插入你需要的可能抛出错误的操作符，比如tryMap等
            .catch { _ in Empty() }
            // 如果需要出错时返回默认值，把上面的Empty()替换为 Just(默认值) 即可
    }
    .setFailureType(to: Never.self)

该方案优势：

• 不需要额外维护Subject实例，适合只需要订阅流的场景
• 单个值处理过程中产生的错误会被捕获，不会终止整个流，后续的正常值可以正常下发

额外说明 #

你之前使用catch的方案会导致流终止，是因为你把catch操作符加在了整个流的末尾，上游发送错误后整个流会被替换为catch返回的Publisher（通常是Just，发送一次值就结束）。把catch移到flatMap内部处理单个值的错误就可以避免这个问题。

如果你能100%保证原有Subject永远不会发送错误，可以直接使用assertNoFailure()操作符直接把失败类型转为Never，但是运行时如果收到错误会直接崩溃，不推荐在不确定的场景使用。

内容的提问来源于stack exchange，提问作者dev_ios999