打印数据
let observable = Observable.of("A", "B", "C")
observable.subscribe { event in
print(event.element)
}
//只处理在指定位置的事件。
.elementAt(2)
.subscribe(onNext: { print($0) })
//取前两个
.take(2)
//取最后一个
.takeLast(1)
//跳过
.skip(2)
//当
.takeWhile { $0 < 4 }
//在开头插入
.startWith("1")
//将多个（两个或两个以上的）Observable 序列合并成一个 Observable序列
.merge()
//对应地凑齐之后再合并。
.zip(subject1, subject2)
//变数组
.toArray()
//一个初始值，和一个操作符号
.reduce(0, accumulator: +)
//串联
.concat()
//延迟3秒才发出
.delay(3, scheduler: MainScheduler.instance) //元素延迟3秒才发出
//看当前 RxSwift 申请的所有资源数量。这个在检查内存泄露的时候非常有用。
print(RxSwift.Resources.total)
网友评论