Combine使用flatMap时出现错误类型不匹配问题求助

问题原因分析 #

第一个错误：No exact matches in call to instance method 'flatMap' #

saveTrigger是PassthroughSubject<Void, Never>，经过map操作后返回的Publisher失败类型仍为Never；但service.save(text:)返回的是AnyPublisher<Void, Error>，失败类型为Error。Combine的flatMap要求上游Publisher的Failure类型必须与闭包返回的Publisher的Failure类型一致，类型不匹配导致编译器无法找到对应的重载方法。

第二个错误：Referencing instance method 'sink(receiveValue:)' on 'Publisher' requires the types 'any Error' and 'Never' be equivalent #

添加.setFailureType(to: Error.self)后，整个流的Failure类型变为Error，但sink(receiveValue:)仅适用于Failure类型为Never的Publisher（即不会产生错误的流）。此时必须使用支持错误处理的sink重载。

解决方案 #

方案1：显式处理错误（推荐） #

使用带receiveCompletion参数的sink重载，同时确保flatMap上下游失败类型一致（这里因为service.save返回Error，上游通过隐式转换或显式声明即可匹配）：

struct Service {
   func save(text: String) -> AnyPublisher<Void, Error> {
      Just(())
        .setFailureType(to: Error.self)
        .eraseToAnyPublisher()
   }
}

let service = Service()
let saveTrigger = PassthroughSubject<Void, Never>()

let cancellable = saveTrigger
   .map { "text to save" }
   .flatMap { text -> AnyPublisher<Void, Error> in
      service.save(text: text)
   }
   .sink(
      receiveCompletion: { completion in
         switch completion {
         case .finished:
             print("保存流程完成")
         case .failure(let error):
             print("保存失败：\(error)")
         }
      },
      receiveValue: {
         print("已保存")
      }
   )

saveTrigger.send(())

方案2：将错误转换为Never类型（忽略错误） #

如果不需要处理错误，可以用catch操作符捕获错误并返回一个Never失败类型的空Publisher，这样就能继续使用sink(receiveValue:)：

let cancellable = saveTrigger
   .map { "text to save" }
   .flatMap { service.save(text: $0) }
   .catch { _ in Empty<Void, Never>() } // 捕获错误，终止流不传递错误
   .sink {
      print("已保存")
   }

注意：此方式会丢失错误信息，仅适用于无需处理错误的场景。

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