1、filter

（1）Definition

Emits only those elements from an Observable sequence that meet the specified 
condition. 
只發(fā)出那些滿足指定條件的事件（elements），將不符合要求的事件過濾掉。

（2）Diagram

filter.png

只會(huì)將 大于10 的 elements 發(fā)出。

（3）Code

// MARK: - filter
func demoForFilter() {
    
    let disposeBag = DisposeBag()
    
    let observable = Observable.of(
        "??", "??", "??",
        "??", "??", "??",
        "??", "??", "??")
    
    observable
        .filter {
            $0 == "??"
        }
        .subscribe(onNext: { print($0) })
        .addDisposableTo(disposeBag)
}

（4）Result

filter 執(zhí)行結(jié)果.png

2、distinctUntilChanged

（1）Definition

Suppresses sequential duplicate elements emitted by an Observable sequence.
禁止序列發(fā)出重復(fù)的 element。即:
當(dāng)下一個(gè)事件與前一個(gè)事件是不同事件的時(shí)候，才會(huì)將其發(fā)出。

（2）Diagram

distinctUntilChanged.png

如果后一個(gè) element 跟前一個(gè) element 重復(fù)了，就不會(huì)發(fā)出后一個(gè) element。

（3）Code

// MARK: - distinctUntilChanged
func demoForDistinctUntilChanged() {
    
    let disposeBag = DisposeBag()
    
    let observable = Observable.of("??", "??", "??", "??", "??", "??", "??")
    
    observable
        .distinctUntilChanged()
        .subscribe(onNext: { print($0) })
        .addDisposableTo(disposeBag)
}

（4）Result

distinctUntilChanged 執(zhí)行結(jié)果.png

3、elementAt

（1）Definition

Emits only the element at the specified index of all elements emitted by an 
Observable sequence.
只會(huì)發(fā)送指定索引的事件(element)

（2）Diagram

elementAt.png

（3）Code

// MARK: - elementAt
func demoForElementAt() {
    
    let disposeBag = DisposeBag()
    
    let observable = Observable.of("??", "??", "??", "??", "??", "??")
    
    observable
        .elementAt(3)
        .subscribe(onNext: { print($0) })
        .addDisposableTo(disposeBag)
}

（4）Result

elementAt 執(zhí)行結(jié)果.png

4、single

（1）Definition

找出在sequence只發(fā)出一次的事件，如果超過一個(gè)就會(huì)發(fā)出error錯(cuò)誤

（2）Diagram

（3）Code & Result

// MARK: - single
func demoForSingle() {
    
    let disposeBag = DisposeBag()
    
    let observable = Observable.of("??", "??", "??", "??", "??", "??")
    
    observable
        .single()
        .subscribe(onNext: { print($0) })
        .addDisposableTo(disposeBag)
}

執(zhí)行結(jié)果如下:
??
Received unhandled error: /Users/XDLee/Desktop/RxSwift/RxSwift_Transform_Operator/RxSwift_Transform_Operator/ViewController.swift:187:demoForSingle() -> 
Sequence contains more than one element.

Observable.of("??", "??", "??", "??", "??", "??")
    .single { $0 == "??" }
    .subscribe { print($0) }
    .addDisposableTo(disposeBag)

執(zhí)行結(jié)果如下:
next(??)
completed

Observable.of("??", "??", "??", "??", "??", "??")
        .single { $0 == "??" }
        .subscribe { print($0) }
        .addDisposableTo(disposeBag)

執(zhí)行結(jié)果如下:
next(??)
error(Sequence contains more than one element.)

Observable.of("??", "??", "??", "??", "??", "??")
            .single { $0 == "??" }
            .subscribe { print($0) }
            .addDisposableTo(disposeBag)

執(zhí)行結(jié)果如下:
error(Sequence contains more than one element.)
error(Sequence doesn't contain any elements.)

5、take

（1）Definition

Emits only the specified number of elements from the beginning of an Observable 
sequence. 
只發(fā)出前幾個(gè)事件（elements）

（2）Diagram

take.png

表示只發(fā)送前2個(gè)事件。

（3）Code

// MARK: - take
func demoForTake() {
    
    let disposeBag = DisposeBag()
    
    let observable = Observable.of("??", "??", "??", "??", "??", "??")
    
    observable
        .take(3)
        .subscribe { print($0) }
        .addDisposableTo(disposeBag)
}

（4）Result

take 執(zhí)行結(jié)果.png

6、takeLast

（1）Definition

表示只發(fā)出后幾個(gè)事件（elements）

（2）Diagram

takeLast.png

（3）Code

// MARK: - takeLast
func demoForTakeLast() {
    
    let disposeBag = DisposeBag()
    
    let observable = Observable.of("??", "??", "??", "??", "??", "??")
    
    observable
        .takeLast(3)
        .subscribe { print($0) }
        .addDisposableTo(disposeBag)
}

（4）Result

takeLast 執(zhí)行結(jié)果.png