
let strikes = PublishSubject<Int>()
let disposeBag = DisposeBag()
strikes
.skip(2)
.subscribe(onNext: { num in
print("(num)")
})
.addDisposableTo(disposeBag)
strikes.onNext(1)
strikes.onNext(2)
strikes.onNext(3)
strikes.onNext(4)
strikes.onNext(5)
strikes.onCompleted()
/* 打印结果
3
4
5
*/
当然除了跳过指定索引号的事件之外,我们依旧通过 skipWhile 我们能够实现类似 filter 类似的操作。只不过 filter 会过滤整个生命周期内的符合条件的事件,而 skipWhile 在找到第一个不符合跳过操作的事件之后就不再工作。例如,下图 skipWhile 的条件是数据为奇数就跳过,但是当数据 2 执行之后 数据 3 虽然也是奇数但是不会在跳过。所以严格意义上来说 skipWhile 可能有点歧义,实际是它会跳过所有符合条件的事件,直到找到第一个能执行事件后就不再生效。

下面是跳过偶数的 skipWhile 代码:
let strikes = PublishSubject<Int>()
let disposeBag = DisposeBag()
strikes
.skipWhile{ num in
num % 2 == 0
}
.subscribe(onNext: { num in
print("(num)")
})
.addDisposableTo(disposeBag)
strikes.onNext(2)
strikes.onNext(2)
strikes.onNext(3)
strikes.onNext(4)
strikes.onNext(5)
strikes.onCompleted()
/* 打印结果
3
4
5
*/
到目前为止,上面的过滤操作都是基于一些静态条件。如果现在你需要根据其它可观察对象实例的行为进行过滤判断怎么办呢?所以接下来将会介绍涉及多实例的动态判断,其中最常见的就是 skipUntil 操作。该操作过程如下图,上面两行表示可观察对象的生命周期而最下面的表示观察者,直到第二行的可观察对象发送数据后第三行的观察者才能接受到第一行发送的数据。

图示对应代码:
let strikes = PublishSubject<String>()
let trigger = PublishSubject<String>()
let disposeBag = DisposeBag()
strikes
.skipUntil(trigger)
.subscribe(onNext: {
print($0)
})
.addDisposableTo(disposeBag)
strikes.onNext("1")
trigger.onNext("X")
strikes.onNext("2")
strikes.onNext("3")
strikes.onCompleted()
/* 打印结果
2
3
*/
Take 过滤
这是一组与 Skip 相反的过滤操作。这组操作中最基础的操作为 take ,该操作的过程完全与 skip 相反。下图演示了 take(2) 操作的过程,它只会对前两个事件进行响应而忽略后面的事件。








