美文网首页
可观察序列(Observable)

可观察序列(Observable)

作者: FallPine | 来源:发表于2018-09-03 16:56 被阅读67次

    创建 Observable 序列

    • just()
    let observable = Observable<Int>.just(5)     // 以默认值5进行初始化
    
    • of()
    let observable = Observable.of("A", "B", "C")   // swift自动推断类型
    
    • from()
    let observable = Observable.from(["A", "B", "C"])   // 传入一个数组
    
    • empty()
    let observable = Observable<Int>.empty()   // 创建一个空序列
    
    • never()
    let observable = Observable<Int>.never()   // 永远不会发出事件,也不会结束
    
    • error()
    enum MyError: Error {
        case A
        case B
    }
             
    let observable = Observable<Int>.error(MyError.A)   // 直接发送错误事件
    
    • range()
    let observable = Observable.range(start: 1, count: 5)   // 只能用于整型数创建序列,该例子表示从1开始,依次递增的5个数的序列
    
    • repeatElement()
    let observable = Observable.repeatElement(1)   // 重复发出给定元素,永不停止,会自动推断类型
    
    • generate()
    /// 只有当提供的判断条件都为true时,才会给出事件
    ///
    /// - Parameter initialState: 初始状态
    /// - Parameter condition: 条件判断
    /// - Parameter iterate: 迭代
    Observable.generate(initialState: <#T##_#>, condition: <#T##(_) throws -> Bool#>, iterate: <#T##(_) throws -> _#>)
    
    let observable = Observable.generate(
        initialState: 1,
        condition: { $0 <= 10 },
        iterate: { $0 + 2 }
    )
            
    observable.subscribe(onNext: { (num) in
        print(num)
    }).disposed(by: disposeBag)
    
    // 输出
    1
    3
    5
    7
    9
    
    • create()
      该方法接受一个 block 形式的参数,对每一个过来的订阅进行处理
    //这个block有一个回调参数observer就是订阅这个Observable对象的订阅者
    //当一个订阅者订阅这个Observable对象的时候,就会将订阅者作为参数传入这个block来执行一些内容
    let observable = Observable<String>.create{observer in
        //对订阅者发出了.next事件,且携带了一个数据"hangge.com"
        observer.onNext("hangge.com")
        //对订阅者发出了.completed事件
        observer.onCompleted()
        //因为一个订阅行为会有一个Disposable类型的返回值,所以在结尾一定要returen一个Disposable
        return Disposables.create()
    }
     
    //订阅测试
    observable.subscribe {
        print($0)
    }
    
    • deferred()
      延迟创建Observable 序列,真正的实例化序列对象是在block中,即Observable 序列是在block中创建后返回的
    //用于标记是奇数、还是偶数
    var isOdd = true
     
    //使用deferred()方法延迟Observable序列的初始化,通过传入的block来实现Observable序列的初始化并且返回,可以根据一些条件在block中返回不同的序列
    let factory : Observable<Int> = Observable.deferred {
         
        //让每次执行这个block时候都会让奇、偶数进行交替
        isOdd = !isOdd
         
        //根据isOdd参数,决定创建并返回的是奇数Observable、还是偶数Observable
        if isOdd {
            return Observable.of(1, 3, 5 ,7)
        }else {
            return Observable.of(2, 4, 6, 8)
        }
    }
     
    //第1次订阅测试
    factory.subscribe { event in
        print("\(isOdd)", event)
    }
     
    //第2次订阅测试
    factory.subscribe { event in
        print("\(isOdd)", event)
    }
    
    • interval()
      每隔一段设定的时间,会发出一个索引数的元素(整数),从0开始,而且不会终止
    let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)   // 一秒发送一个元素
    
    • timer()
      1、创建的 Observable 序列,在经过设定的一段时间后,产生唯一的一个元素

      let observable = Observable<Int>.timer(5, scheduler: MainScheduler.instance)
      

      2、创建的 Observable 序列,在经过设定的一段时间后,每隔一段时间产生一个元素

      let observable = Observable<Int>.timer(5, period: 1, scheduler: MainScheduler.instance)
      

    参考文章:Swift - RxSwift的使用详解3(Observable介绍、创建可观察序列)

    相关文章

      网友评论

          本文标题:可观察序列(Observable)

          本文链接:https://www.haomeiwen.com/subject/gxqiwftx.html