1、filter

（1）Definition

Emits only those elements from an Observable sequence that meet the specified 
condition. 
只发出那些满足指定条件的事件（elements），将不符合要求的事件过滤掉。

（2）Diagram

filter.png

只会将 大于10 的 elements 发出。

（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 执行结果.png

2、distinctUntilChanged

（1）Definition

Suppresses sequential duplicate elements emitted by an Observable sequence.
禁止序列发出重复的 element。即:
当下一个事件与前一个事件是不同事件的时候，才会将其发出。

（2）Diagram

distinctUntilChanged.png

如果后一个 element 跟前一个 element 重复了，就不会发出后一个 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 执行结果.png

3、elementAt

（1）Definition

Emits only the element at the specified index of all elements emitted by an 
Observable sequence.
只会发送指定索引的事件(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 执行结果.png

4、single

（1）Definition

找出在sequence只发出一次的事件，如果超过一个就会发出error错误

（2）Diagram

（3）Code & Result

// MARK: - single
func demoForSingle() {
    
    let disposeBag = DisposeBag()
    
    let observable = Observable.of("🐱", "🐰", "🐶", "🐸", "🐷", "🐵")
    
    observable
        .single()
        .subscribe(onNext: { print($0) })
        .addDisposableTo(disposeBag)
}

执行结果如下:
🐱
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)

执行结果如下:
next(🐸)
completed

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

执行结果如下:
next(🐰)
error(Sequence contains more than one element.)

Observable.of("🐱", "🐰", "🐶", "🐸", "🐷", "🐵")
            .single { $0 == "🔵" }
            .subscribe { print($0) }
            .addDisposableTo(disposeBag)

执行结果如下:
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. 
只发出前几个事件（elements）

（2）Diagram

take.png

表示只发送前2个事件。

（3）Code

// MARK: - take
func demoForTake() {
    
    let disposeBag = DisposeBag()
    
    let observable = Observable.of("🐱", "🐰", "🐶", "🐸", "🐷", "🐵")
    
    observable
        .take(3)
        .subscribe { print($0) }
        .addDisposableTo(disposeBag)
}

（4）Result

take 执行结果.png

6、takeLast

（1）Definition

表示只发出后几个事件（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 执行结果.png