ReactiveX RxSwift从可观测数据的连接中获得第一个非错误

import RxSwift

let observable = Observable<String>.create { observer in
    // 模拟异步数据产生
    DispatchQueue.main.asyncAfter(deadline: .now() + 1) {
        observer.onNext("Data 1")
        observer.onNext("Data 2")
        observer.onError(MyError.someError)
        observer.onNext("Data 3")
        observer.onCompleted()
    }
    
    return Disposables.create()
}

observable
    .filter { !$0.isEmpty } // 过滤掉空字符串
    .first()
    .subscribe(
        onNext: { element in
            print("第一个非错误的元素是：\(element)")
        },
        onError: { error in
            print("发生错误：\(error)")
        }
    )
    .disposed(by: disposeBag)