可观察序列（Observable）

创建 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介绍、创建可观察序列）