如何重试不同输入的请求?

Question

目标用不同的输入数据进行重试。

func generateRandomName() -> Int { ... }
checkIfNameIsAvailable(generateRandomName())
.retry(10) // <- Makes 10 attempts with same link
.sink(
receiveCompletion: { completion in
},
receiveValue: { value in
// Do things
}
)
.store(in: &cancellables)

如何修改retry以不同的上游(请求不同的查询参数)重试10次?

Answer 1

您可以使用一些高阶函数来实现此目标。

像下面这样:

func retry<P: Publisher>(_ times: Int, _ publisherBuilder: @escaping () -> P) -> AnyPublisher<P.Output, P.Failure> {
if times <= 1 {
return publisherBuilder().eraseToAnyPublisher()
} else {
return publisherBuilder()
.catch { _ in retry(times-1, publisherBuilder) }
.eraseToAnyPublisher()
}
}

该函数接受多次重试和一个发布者构建器闭包作为参数。这为您在重审路径上生成新的发布者提供了灵活性，因为每次重审都将调用闭包:

retry(10) { checkIfNameIsAvailable(generateRandomName()) }
.sink(
receiveCompletion: { completion in
},
receiveValue: { value in
// Do things
}
)
.store(in: &cancellables)

Answer 2

您不能使用retry。那不是retry做的。

这里有一个不同的策略:

1. 发布一个包含10个元素的序列
2. 将这些元素转换成一个查询。
3. 将每个查询平铺映射到查询结果的发布者。
4. 取平面地图的单元素前缀

:

func generateRandomName(seed: Int) -> String {
return "name(seed)"
}
struct NameTakenError: Error { }
func availableNamePublisher(name: String) -> AnyPublisher<String, Error> {
print("checking availability of (name)")
if
let digit = name.last?.wholeNumberValue,
digit > 3
{
return Result.success(name).publisher.eraseToAnyPublisher()
} else {
return Result.failure(NameTakenError()).publisher.eraseToAnyPublisher()
}
}
let ticket = (0 ..< 10).publisher
.map { i in generateRandomName(seed: i) }
.flatMap(maxPublishers: .max(1)) { name in
availableNamePublisher(name: name)
.catch { _ in Empty() }
}
.prefix(1)
.sink(
receiveCompletion: { print("completion: ($0)") },
receiveValue: { print("available name: ($0)") }
)

输出:

checking availability of name0
checking availability of name1
checking availability of name2
checking availability of name3
checking availability of name4
available name: name4
completion: finished