swift - Rx swift : Extra argument 'onError' when subscribing on an Observable

Question

我有以下代码:

let fetcher = DiagnosticFetcher(commandSender: sender)
fetcher.fetch()
    .observeOn(MainScheduler.instance)
    .subscribe(
       onNext: { self.store.save(content: $0) },
       onError: { self.view.showError("Error") },
       onCompleted: { log.verbose("Diagnostic fetched") })

它不编译:Extra argument 'onError' in call .如果我使用 onSuccess，我会得到同样的错误或 onDoesNotExistButShowTheBug而不是 onNext .

fetch()方法返回 Observable<String> (其最后一个运算符是 reduce )。似乎 subscribe()调用只需要一个 lambda:

fetcher.fetch()
   .observeOn(MainScheduler.instance)
   .subscribe(onNext: { self.store.save(content: $0) })

结果:Extraneous argument label 'onNext:' in call .并且:

fetcher.fetch()
   .observeOn(MainScheduler.instance)
   .subscribe({ self.store.save(content: $0) })

编译正常。

我感觉我听错了subscribe()执行。我想要那个:

public func subscribe(onNext: ((ElementType) -> Void)? = nil,
                      onError: ((Swift.Error) -> Void)? = nil,
                      onCompleted: (() -> Void)? = nil) -> Disposable {

但显然，编译器不会。我将 XCode 9.2 与 Swift 4 和 RxSwift 4.1.1 结合使用。

我的应用程序中还有其他部分使用 onNext:onError:在它工作的可观察对象上。我无法确定这次通话有何不同。

关于如何确定问题根源的任何想法？

Answer 1

我通过在 onError lambda 中指定第一个参数来编译它:

fetcher.fetch()
   .observeOn(MainScheduler.instance)
   .subscribe(
      onNext: { self.store.save(content: $0) },
      onError: { _ in self.view.showError("Error")})