创建 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)
