rxswift读书笔记

打印数据

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)