Swift Combine：如何处理事件和继续流

Question

我正在使用 Swift Combine 实现一个带有登录功能的库。

使用以下代码，我已经能够登录，将响应序列化为对象 AuthenticationResult，并返回一个带有 User 或 ApiError 结果的 Publisher。

作为响应（AuthenticationResult 对象）的一部分，我还从 API 获取了一个 accessToken。我想将该令牌保存在本地作为此流的一部分。但我希望这在库内部完成，以便登录功能的响应不会改变。

有没有办法处理流中的这种情况，处理事件，然后继续流返回用户？

func authenticate(username: String, password: String) -> AnyPublisher<User, ApiError> {
    let parameters: [String: Any] = [
        "username": username,
        "pw": password
    ]

    var request = URLRequest(endpoint: Endpoint.login)
    request.addValue("application/json", forHTTPHeaderField: "Content-Type")
    request.httpBody = try? JSONSerialization.data(withJSONObject: parameters, options: [])

    return URLSession.shared.dataTaskPublisher(for: request)
        .map { $0.data }
        .decode(type: AuthenticationResult.self, decoder: JSONDecoder())
        .map { $0.user }
    // Here I would like to do something like: .handleAndContinue { self.save($0.accessToken }
        .mapError { _ in ApiError.loginError }
        .receive(on: RunLoop.main)
        .eraseToAnyPublisher()
}

或者有没有其他方法可以使用 Swift Combine 处理这种情况？

Answer 1

这可以通过以下方式完成：

        .handleEvents(receiveOutput: {
            self.save($0.accessToken)
        })