如何将Combine中的Publisher转换为不同类型的Publisher?
问题分析
你遇到的类型不匹配错误,核心原因是误用了map操作符。map会将上游的EulaDataModel直接转换成AnyPublisher<EULAEntity, Error>,最终得到的是一个“发布Publisher的Publisher”(类型为Publishers.Map<AnyPublisher<EulaDataModel, ApiError>, AnyPublisher<EULAEntity, Error>>),但你需要的是直接发布EULAEntity的AnyPublisher<EULAEntity, Error>,两者类型完全不兼容。
解决方案
有两种更合理的实现方式,根据你的场景选择:
方式一:用flatMap展平内部Publisher(适配现有publisherConver方法)
如果想保留现有的publisherConver方法,只需把map换成flatMap——它会自动展平内部的Publisher,将嵌套的Publisher流合并成单一的EULAEntity流:
func termsAcceptanceStatus()-> AnyPublisher<EULAEntity, Error> { let signal = networkService.sendRequest(router: EulaRouter.getEula).combineResponse(decodingType: EulaDataModel.self) return signal.flatMap { data -> AnyPublisher<EULAEntity, Error> in self.publisherConver(from: data) }.eraseToAnyPublisher() }
方式二:直接用map同步转换(更简洁)
由于你的convertModel是同步转换操作,完全不需要额外包一个Just Publisher,直接用map就能完成类型转换,代码更简洁:
func termsAcceptanceStatus()-> AnyPublisher<EULAEntity, Error> { let signal = networkService.sendRequest(router: EulaRouter.getEula).combineResponse(decodingType: EulaDataModel.self) return signal.map { data in self.convertModel(model: data) }.eraseToAnyPublisher() } // 保留原有的convertModel方法,可去掉publisherConver方法 func convertModel(model: EulaDataModel) -> EULAEntity { return EULAEntity(agreed: model.legalTermsAccepted) }
关键知识点
map:用于同步转换上游输出的单个值,输出类型是转换后的单个值,不会产生嵌套Publisher。flatMap:用于将上游值转换成一个新的Publisher,并将这个新Publisher的输出合并到当前流中,解决嵌套Publisher的问题,适用于异步转换场景。
内容的提问来源于stack exchange,提问作者dubbeat
相关产品推荐
相关产品推荐

