在另一个出版商的地图中使用出版商​​的结果

问题描述

例如，我有一个基本的已发布值，例如

@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()
  }
}