3

我从一个 RESTful 服务器加载端点，其中一些是多页的。它们由标头响应中的“x-pages”字段表示。我想创建一个发布者，它将所有页面中的所有对象作为单个数组返回。

最后一个 return 语句存在编译错误。

Cannot convert return expression of type 'AnyPublisher<AnyPublisher<[T], LoadingError>, LoadingError>\' to return type 'AnyPublisher<[T], LoadingError>'

如何修复这个“嵌入式”发布者？

import Combine
import Foundation

enum LoadingError: Error {
    case url(URLError)
    case decode(Error)
    case couldNotDetermieLastPageNumber(URL)
}

func multipageDataTaskPublishter<T>(for endpoint: Endpoint) -> AnyPublisher<[T], LoadingError> where T: Decodable {
    assert(endpoint.page == 1)
    let publisher = URLSession.shared.dataTaskPublisher(for: endpoint.url)
        .retry(1)
        .mapError { LoadingError.url($0) }
        .map { (arg) -> AnyPublisher<[T], LoadingError> in
            let (_, response) = arg
            guard
                let header = response as? HTTPURLResponse,
                let xpages = header.value(forHTTPHeaderField: "x-pages"),
                let lastPage = Int(xpages)
            else {
                return Fail(error: LoadingError.couldNotDetermieLastPageNumber(endpoint.url))
                    .eraseToAnyPublisher()
            }

            let publishers = (1...lastPage).map { page -> AnyPublisher<[T], LoadingError> in
                let next = endpoint.for(page: page)
                return URLSession.shared.dataTaskPublisher(for: next.url)
                    .retry(1)
                    .mapError { LoadingError.url($0) }
                    .map { $0.data }
                    .decode(type: [T].self, decoder: JSONDecoder())
                    .mapError { LoadingError.decode($0) }
                    .eraseToAnyPublisher()
            }
            return Publishers.Sequence(sequence: publishers)
                .flatMap { $0 }
                .reduce([], +)
                .eraseToAnyPublisher()
        }
    return publisher.eraseToAnyPublisher()
}

在创建多页发布者时，我可以在防护之后立即添加一个接收器以读取 lastPage 值。然后将let publishers = ...部分从地图中提升一级，我的 Publishers.Sequence 返回值将是正确的。但这在很多层面上似乎都是错误的。拆分执行，不可组合。

此外，我意识到我的实现加载了第一页两次。稍后拆分管道并合并数据有效负载会更好，我想找到那个解决方案，但我需要先解决这个问题。如果这是一个无望的原因，那么就这样吧，任何惯用的组合解决方案都将被接受。

4

1 回答 1

2

此行.map { (arg) -> AnyPublisher<[T], LoadingError> in必须是flatMap.

于 2019-09-06T11:05:06.723 回答