如何使用 dataTaskPublisher 链接多个 API 调用?
How to chain multiple API calls using dataTaskPublisher?
我想从 REST API 获取数据,为此,我需要先获取 ID 数组 - 第一次调用。之后,我需要使用每个 ID 进行 API 调用。我不想使用 completionHandlers,而是使用 Combine。我从 dataTaskPublishers 开始,但我不确定如何将它们链接起来才能正常工作
到目前为止,这是我的代码:
private func getIDs(for type: DataType) -> AnyPublisher<[ID], Error> {
guard let url = URL(string: "url")
else { fatalError("Wrong URL") }
return session.dataTaskPublisher(for: url)
.receive(on: RunLoop.main)
.map { [=11=].data }
.decode(type: [ID].self, decoder: decoder)
.eraseToAnyPublisher()
}
private func getData(with id: ID) -> AnyPublisher<MyData, Error> {
guard let url = URL(string: "url_with_id")
else { fatalError("Wrong URL") }
return session.dataTaskPublisher(for: url)
.receive(on: RunLoop.main)
.map { [=11=].data }
.decode(type: MyData.self, decoder: decoder)
.eraseToAnyPublisher()
}
我不太确定如何连接它们以获得可分配给我的状态变量的东西 - MyData 数组。
如, you can use collect()
中所建议:
func getAllData(for type: DataType) -> AnyPublisher<[MyData], Error> {
getIDs(for: type).flatMap { ids in
Publishers.Sequence(sequence: ids.map { self.getData(with: [=10=]) })
.flatMap { [=10=] }
.collect()
}.eraseToAnyPublisher()
}
我想从 REST API 获取数据,为此,我需要先获取 ID 数组 - 第一次调用。之后,我需要使用每个 ID 进行 API 调用。我不想使用 completionHandlers,而是使用 Combine。我从 dataTaskPublishers 开始,但我不确定如何将它们链接起来才能正常工作
到目前为止,这是我的代码:
private func getIDs(for type: DataType) -> AnyPublisher<[ID], Error> {
guard let url = URL(string: "url")
else { fatalError("Wrong URL") }
return session.dataTaskPublisher(for: url)
.receive(on: RunLoop.main)
.map { [=11=].data }
.decode(type: [ID].self, decoder: decoder)
.eraseToAnyPublisher()
}
private func getData(with id: ID) -> AnyPublisher<MyData, Error> {
guard let url = URL(string: "url_with_id")
else { fatalError("Wrong URL") }
return session.dataTaskPublisher(for: url)
.receive(on: RunLoop.main)
.map { [=11=].data }
.decode(type: MyData.self, decoder: decoder)
.eraseToAnyPublisher()
}
我不太确定如何连接它们以获得可分配给我的状态变量的东西 - MyData 数组。
如collect()
中所建议:
func getAllData(for type: DataType) -> AnyPublisher<[MyData], Error> {
getIDs(for: type).flatMap { ids in
Publishers.Sequence(sequence: ids.map { self.getData(with: [=10=]) })
.flatMap { [=10=] }
.collect()
}.eraseToAnyPublisher()
}