合并sink：忽略receiveValue，只需要完成

Question

考虑以下代码：

        CurrentValueSubject<Void, Error>(())
            .eraseToAnyPublisher()
            .sink { completion in

                switch completion {
                case .failure(let error):
                    print(error)
                    print("FAILURE")
                case .finished:
                    print("SUCCESS")
                }
            } receiveValue: { value in
                // this should be ignored
            }

只需查看 CurrentValueSubject 初始化程序，就可以清楚地看出该值不需要/无关紧要。

我正在使用这个特定的发布者发出一个异步网络请求，该请求可以通过也可以失败。

由于我对此发布者返回的值不感兴趣（没有），我怎样才能摆脱 receiveValue 闭包？

理想情况下，调用站点代码应如下所示：

        CurrentValueSubject<Void, Error>(())
            .eraseToAnyPublisher()
            .sink { completion in

                switch completion {
                case .failure(let error):
                    print(error)
                    print("FAILURE")
                case .finished:
                    print("SUCCESS ")
                }
            }

也可能是我应该使用 AnyPublisher 以外的其他东西，所以如果它更适合目的，请随意提出/重写 API。

我能找到的最接近的解决方案是ignoreOutput，但它仍然返回一个值。

Answer 1

您可以通过完成来声明另一个接收器：

extension CurrentValueSubject where Output == Void {
    
    func sink(receiveCompletion: @escaping ((Subscribers.Completion<Failure>) -> Void)) -> AnyCancellable {
        sink(receiveCompletion: receiveCompletion, receiveValue: {})
    }
}

Answer 2

CurrentValueSubject 似乎是一个令人困惑的选择，因为当您第一次订阅它时，它将发送一个初始值（Void）。

您可以使用Future 使事情变得不那么模糊，它会在完成后发送一个且唯一的值。

为了避免接收您不关心的值，您可以翻转情况并使用Result<Void, Error> 的输出类型和Never 的失败类型。在处理您的网络请求时，您可以使用.failure(error) 或.success(()) 履行承诺，并在 sink 中处理：

let pub = Future<Result<Void, Error>, Never> {
    promise in
    // Do something asynchronous
    DispatchQueue.main.asyncAfter(deadline: .now() + 1) {
        promise(.success(.success(())))
        //or
        //promise(.success(.failure(error)))
    }
}.eraseToAnyPublisher()

// somewhere else...
pub.sink {
    switch $0 {
    case .failure(let error):
        print("Whoops \(error)")
    case .success:
        print("Yay")
    }
}

您正在将链的一端的丑陋代码交换为另一端的丑陋代码，但如果它隐藏在 AnyPublisher 后面并且您担心正确使用，那似乎是要走的路。消费者可以通过查看输出和错误类型确切地看到预期的结果，而不必在单独的闭包中处理它们。