上图对应代码：
let strikes = PublishSubject<String>()
let disposeBag = DisposeBag()
strikes
.take(2)
.subscribe(onNext: {
print($0)
})
.addDisposableTo(disposeBag)
strikes.onNext("1")
strikes.onNext("2")
strikes.onNext("3")
strikes.onCompleted()
/* 打印结果
1
2
*/
除此之外，skipWhile 也有对应的 Take 操作 takeWhile ，两者的代码结构几乎一致只不过前者是跳过操作而后者则是响应操作。不过这里我不准备介绍 takeWhile 操作（可以自己动手试下），而是介绍 takeWhile 变种 takeWhileWithIndex。其实函数名已经表明了该操作的主要功能，在 takeWhile 的基础上会加上索引 index 参数。因为有时候我们除了需要通过 value 进行过滤判断外，索引 index 也可能是一个判断维度。下图就展示了 takeWhileWithIndex 简单使用示例，对于 value 和 index 值小于 1 的事件全部跳过。
图示对应代码：
let strikes = PublishSubject<Int>()
let disposeBag = DisposeBag()
strikes
.takeWhileWithIndex { integer, index in
integer > 1 && index > 1
}
.subscribe(onNext: {
print( "($0)")
})
.addDisposableTo(disposeBag)
strikes.onNext(1)
strikes.onNext(2)
strikes.onNext(3)
strikes.onCompleted()
/* 打印结果
3
*/
其实 Skip 组中同样存在与 takeWhileWithIndex 相对的 skipWhileWithIndex ，感兴趣可以自己检验一下。接下来我们介绍 Take 组中的最后一个操作 takeUntil 。同样地该操作是 skipUntil 的反操作，直到另一个实例对象触发后该实例对象的观察者才会停止响应。下图就是 takeUntil 操作的一个简单示例，作为观察者第三行会一直响应第一行可观察对象发送的数据，直到第二行对象触发后才停止。
对应代码：
let strikes = PublishSubject<String>()
let trigger = PublishSubject<String>()
let disposeBag = DisposeBag()
strikes
.takeUntil(trigger)
.subscribe(onNext: {
print($0)
})
.addDisposableTo(disposeBag)
strikes.onNext("1")
strikes.onNext("2")
trigger.onNext("X")
strikes.onNext("3")
strikes.onCompleted()
/* 打印结果
1
2
*/
