rxswift网络序列顺序请求

rxswift_netsequence_list.swift

        
        enum TestError: Error {
            case errorcatch
        }
        
        var count = 1
        let symbol1 = Observable<String>.create { (observer) -> Disposable in
            observer.onNext("symbol1--------test")
            
            if count == 1 {
                observer.onError(TestError.errorcatch)
                count += 1
            }
            
            observer.onNext("symbol1--------test1")
            
            observer.onCompleted()
            
            return Disposables.create()
        }
        
        let symbol2 = Observable<String>.create { (observer) -> Disposable in
            observer.onNext("symbol2--------test")
            
            return Disposables.create()
        }
        
        let symbols = Observable.of(symbol1, symbol2)
        symbols.concat().retry(2).subscribe(onNext: { (text) in
            print(text)
        }).dispose()