過濾操作符（Filter）

• ignoreElements

過濾掉所有的.next事件

let strikes = PublishSubject<String>()
let disposeBag = DisposeBag()
strikes.ignoreElements().subscribe { _ in
    print("You're out!")
}
.disposed(by: disposeBag)

• elementAt

只取elementAt指定的一個(gè)事件青柄，其他事件全部忽略

let strikes = PublishSubject<String>()
let disposeBag = DisposeBag()
strikes.elementAt(2).subscribe(onNext: { _ in
    print("You're out!")
})
.disposed(by: disposeBag)

• filter

只取滿足filter條件的

let disposeBag = DisposeBag()
Observable.of(1, 2, 3, 4, 5, 6).filter { integer in
      integer % 2 == 0
}.subscribe(onNext: {
      print($0)
})
.disposed(by: disposeBag)

跳過操作符（Skip）

• skip

跳過前面幾個(gè)事件

let disposeBag = DisposeBag()
Observable.of("A", "B", "C", "D", "E", "F").skip(3).subscribe(onNext: {
  print($0) 
})
.disposed(by: disposeBag)

• skipWhile

跳過所有滿足條件的事件旭绒，直到碰到一個(gè)不滿足條件的事件弃鸦，發(fā)送這個(gè)不滿足條件的事件赴精，及后面所有的事件晚凿。

let disposeBag = DisposeBag()
Observable.of(2, 2, 3, 4, 4)
.skipWhile { integer in
  integer % 2 == 0
}.subscribe(onNext: {
  print($0)
})
.disposed(by: disposeBag)

• skipUntil

同時(shí)監(jiān)聽另外一個(gè)Observerable颈畸，只有這個(gè)Observerable發(fā)送了next事件伊佃，才會(huì)接收本身的事件

let disposeBag = DisposeBag()
let subject = PublishSubject<String>()
let trigger = PublishSubject<String>()
subject.skipUntil(trigger).subscribe(onNext: {
  print($0) 
})
.disposed(by: disposeBag)

取操作符（Take）

和Skip事件相反

• take

取前面幾個(gè)事件

let disposeBag = DisposeBag()
Observable.of(1, 2, 3, 4, 5, 6).take(3).subscribe(onNext: {
  print($0) 
})
.disposed(by: disposeBag)

• takeWhile

取所有滿足條件的事件响蕴，直到碰到一個(gè)不滿足條件的事件骤铃，這個(gè)不滿足條件的事件拉岁，及后面所有的事件都忽略

let disposeBag = DisposeBag()
Observable.of(2, 2, 4, 4, 6, 6)
  .enumerated()
  .takeWhile { index, integer in
    integer % 2 == 0 && index < 3
  }
  .subscribe(onNext: {
    print($0) 
    })
  .disposed(by: disposeBag)

.enumerated()的作用是，給序列生成索引index

• takeWhile

同時(shí)監(jiān)聽另外一個(gè)Observerable惰爬，只有這個(gè)Observerable發(fā)送了next事件喊暖，才停止接收本身的事件

let disposeBag = DisposeBag()
let subject = PublishSubject<String>()
let trigger = PublishSubject<String>()
subject.takeUntil(trigger).subscribe(onNext: {
  print($0) 
})
  .disposed(by: disposeBag)

變化操作符（Distinct）

• distinctUntilChanged

過濾掉連續(xù)一樣的事件，注意是連續(xù)撕瞧，例如"A", "A", "B", "B", "A"陵叽，那么過濾后的事件是"A", "B", "A"。

let disposeBag = DisposeBag()
Observable.of("A", "A", "B", "B", "A")
  .distinctUntilChanged()
  .subscribe(onNext: {
    print($0) 
    })
  .disposed(by: disposeBag)

事件是不是“一樣“的判斷丛版，默認(rèn)是根據(jù)Equatable協(xié)議判斷巩掺。也可以直接設(shè)定條件。

.distinctUntilChanged {
  // 判斷條件页畦，返回bool值
}