如何解决在另一个出版商的地图中使用出版商的结果
例如,我有一个基本的已发布值,例如
@Published var value: String
我想验证我的表单的这个值以给我的用户一个输出。为此,我将在我的 MVVM 项目中使用 Combine。
现在需要根据我的 REST API 验证这种类型的值。对于我的 REST API,我已经有了一个方法来获取我喜欢的结果 getFirstMailboxRedirectFromAPI
,它返回 AnyPublisher<MailboxAPIResponse,APIError>
。 MailboxAPIResponse 是 api 响应的可解码对象。因此,如果我只想显示结果,我会使用 .sink
创建一个订阅者,将结果添加到将显示在视图中的变量中。到目前为止这么好。现在我的问题:
如第一部分所述,我的值已经是一个发布者(因为@Published),我可以在其中做一些 .map
的事情来验证它,如果一切正常,则返回 true 或 false。
所以为了验证我发布的值,我需要调用我的另一个发布者,它使用 API 来检查该值是否已经存在。但我不知道这应该如何工作。
到目前为止,这是我的代码,但这不起作用。但这向你展示了我的想法它应该如何工作。
private var isMailboxRedirectNameAvailablePublisher: AnyPublisher<Bool,Never> {
$mailboxRedirectName
.debounce(for: 0.5,scheduler: RunLoop.main)
.setFailureType(to: Error.self)
.flatMap { name in
self.getFirstMailboxRedirectFromAPI(from: name,and: self.domainName)
.map { apiResponse in
return apiResponse.response.data.count == 0
}
}
.eraseToAnyPublisher()
}
因此,发布者应该使用 redirectName 来调用 API,如果邮箱已经存在,API 会给我结果,然后返回一个布尔值,如果它存在与否。
如何嵌套多个发布者并在我的已发布值发布者中使用 API 发布者的结果?
解决方法
我稍微简化了一点,但关键是 1) 如果您希望操作重新启动,请使用 switchToLatest 将发布者的发布者展平(flatMap 是一个合并,因此事件可能无序到达)。 2)您需要处理失败类型并确保内部发布者永远不会失败,否则外部发布者也会完成。
final class M: ObservableObject {
@Published var mailboxRedirectName: String = ""
private var isMailboxRedirectNameAvailablePublisher: AnyPublisher<Bool,Never> {
$mailboxRedirectName
.debounce(for: 0.5,scheduler: DispatchQueue.main)
.map { [weak self] name -> AnyPublisher<Bool,Never> in
guard let self = self else { return Just(false).eraseToAnyPublisher() }
return self
.getFirstMailboxRedirectFromAPI(from: name)
.replaceError(with: false)
.eraseToAnyPublisher()
}
.switchToLatest()
.eraseToAnyPublisher()
}
func getFirstMailboxRedirectFromAPI(from name: String) -> AnyPublisher<Bool,Error> {
Just(true).setFailureType(to: Error.self).eraseToAnyPublisher()
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。