Swift中使用Combine无法完成模型类型间映射的问题

原代码与错误信息 #

Repository层代码 #

public final class TimeTableRepository: TimeTableRepositoryProtocol {
    private let timeTableRemoteDataSource: TimeTableRemoteDataSource
    
    init(timeTableRemoteDataSource: TimeTableRemoteDataSource) {
        self.timeTableRemoteDataSource = timeTableRemoteDataSource
    }
    
    func getTimeTable() -> AnyPublisher<[TimeTableEntity]?, Error> {
        timeTableRemoteDataSource.getTimeTable().flatMap { return $0.toDomain() }
    }
}

模型转换扩展 #

extension TimetableModel {
    func toDomain() -> [TimeTableEntity]? {
        timetable.departures.map{ TimeTableEntity(lineDirection: $0.lineDirection ?? "", ThroughStations: $0.throughTheStations ?? "", timestamp: $0.datetime.timestamp, timezone: $0.datetime.tz) }
    }
}

错误提示 #

'flatMap(maxPublishers:_:)' produces 'Publishers.FlatMap<[TimeTableEntity]?, AnyPublisher<TimetableModel, any Error>>', not the expected contextual result type 'AnyPublisher<[TimeTableEntity]?, any Error>' (Combine.Publisher)

问题分析 #

错误核心是操作符使用与类型处理不当：

• flatMap用于将上游输出转换为另一个Publisher并订阅，但toDomain()直接返回[TimeTableEntity]?（普通可选数组值），并非Publisher类型，导致类型不兼容。
• 原代码未将最终Publisher类型擦除为协议要求的AnyPublisher，进一步加剧类型不匹配问题。

修复后的代码 #

public final class TimeTableRepository: TimeTableRepositoryProtocol {
    private let timeTableRemoteDataSource: TimeTableRemoteDataSource
    
    init(timeTableRemoteDataSource: TimeTableRemoteDataSource) {
        self.timeTableRemoteDataSource = timeTableRemoteDataSource
    }
    
    func getTimeTable() -> AnyPublisher<[TimeTableEntity]?, Error> {
        timeTableRemoteDataSource.getTimeTable()
            .map { $0.toDomain() } // 用map替换flatMap，处理普通值类型转换
            .eraseToAnyPublisher() // 擦除具体Publisher类型，匹配协议返回值要求
    }
}

关键说明 #

1. 替换flatMap为map：map操作符专门用于将上游输出值转换为其他类型的普通值，完全适配toDomain()的返回类型。
2. 添加eraseToAnyPublisher()：Combine中每个操作符会生成特定的Publisher子类（如这里的Publishers.Map），而协议要求返回AnyPublisher，必须通过该方法擦除具体类型，保证类型一致性。

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