/// 1. ignoreElements : 忽略所有的 .next 事件元素，允许停止事件通过，如 .completed 和 .error.
/// 也许会发现：ignoreElements 实际上返回一个 Completable
example(of: "ignoreElements") {
    // 1. 创建 subject
    let strikes = PublishSubject<String>()
    let disposeBag = DisposeBag()
    // 2. 添加订阅
    strikes
        .ignoreElements() // 忽略所有元素
        .subscribe{_ in
            print("You are out!")
        }
        .disposed(by: disposeBag)
    
    strikes.onNext("X") // 无输出
    strikes.onNext("Y") // 无输出
    
    strikes.onCompleted() // 输出 You are out!
}

/// 2. elementAt : 获取指定位置的元素。
/// 只要获取到指定位置的元素，订阅就终止。
example(of: "elementAt") {
    let strikes = PublishSubject<String>()
    let bag = DisposeBag()
    
    strikes
        .elementAt(2) // 获取序列中 index = 2 的元素
        .subscribe(onNext: { element in
            print("\(element) - You are out!")
        })
        .disposed(by: bag)
    strikes.onNext("X") // 无输出
    strikes.onNext("Y") // 无输出
    strikes.onNext("Z") // index = 2 输出
    
    // 输出：Z - You are out!
}

/// 3. ignoreElement 和 elementAt 过滤序列元素。有时不针对全部或单个元素操作。
/// filter 提供了一个闭包，针对所有的元素，只要满足添加就可以输出。
example(of: "filter") {
    let bag = DisposeBag()
    // 1. 创建一个序列
    Observable.of(1, 2, 3, 4, 5, 6)
        .filter{ $0 % 2 == 0} // 2. 过滤偶数
        .subscribe(onNext: { // 3. 订阅
            print($0)
        })
        .disposed(by: bag)
    // 输出： 2 4 6
}

/// 1. skip() : 跳过指定数量的元素

example(of: "skip") {
    let bag = DisposeBag()
    
    // 1. 序列
    Observable.of("A", "B", "C", "D", "E", "F")
        .skip(3) // 2. 跳过三个元素
        .subscribe( onNext: { // 3. 订阅
            print($0)
        })
        .disposed(by: bag)
    // 输出： D E F
}

/// 2. skipWhile : 像 skip 一样决定哪些元素被忽略。
/// skipWhile 只跳过元素，直到第一个元素被允许通过，然后所有剩余的元素都被允许通过。
/// 闭包 返回 true 对应的元素将被忽略；返回 false 对应的元素通过。
/// 与 filter 操作相反。
example(of: "skipWhile") {
    let bag = DisposeBag()
    
    Observable.of(2, 2, 3, 4, 4) // 1. 序列
        .skipWhile { $0 % 2 == 0} // 2. 跳过 开始时的 偶数
        .subscribe(onNext: {
            print($0)
        })
        .disposed(by: bag)
    // 输出： 3 4 4
}

/// 以上都是静态的条件过滤元素，如果想基于其他序列动态过滤元素怎么办？
/// 3. skipUntil : 它将保持跳过原序列所有元素，直到触发序列发射 .next 事件，开始输出后续元素。
example(of: "skipUntil") {
    let bag = DisposeBag()
    // 1. 一个源序列，一个触发序列
    let subject = PublishSubject<String>()
    let trigger = PublishSubject<String>()
    
    // 2.
    subject
        .skipUntil(trigger) // 直到 trigger 序列有 .next 事件
        .subscribe(onNext: {
            print($0)
        })
        .disposed(by: bag)
    
    subject.onNext("A")
    subject.onNext("B") // 未输出
    trigger.onNext("X") // 触发
    subject.onNext("C")
    
    // 输出：C
}

/// Taking 是与 Skipping 相反的操作。
/// 1. take: 获取几个元素
example(of: "take") {
    let bag  = DisposeBag()
    
    Observable.of(4, 5, 6, 7, 8, 9)
        .take(3) // 获取三个元素
        .subscribe(onNext: {
            print($0)
        })
        .disposed(by: bag)
    // 输出： 4 5 6
}

/// 2. takeWhile: 与 skipWhile 类似，不同点是用 taking 代替 skipping
example(of: "takeWhile") {
    let bag = DisposeBag()
    
    Observable.of(2, 2, 4, 4, 6, 6)
        .enumerated() // 1. 获取元组包含 index 和 element
        .takeWhile({ index, integer in // 2. 直到条件不成立停止
            integer % 2 == 0 && index < 3
        })
        .map { $0.element } // 3. 获取元素，生成只包含元素的序列
        .subscribe(onNext: { // 4. 订阅输出
            print($0)
        })
        .disposed(by: bag)
    
    // 输出： 2 2 4
}

/// 3. takeUntil: 与 skipUntil 类似
/// 持续获取源序列中元素，直到触发序列发送 .next 事件。
example(of: "takeUntil") {
    let bag = DisposeBag()
    // 1.
    let subject = PublishSubject<String>()
    let trigger = PublishSubject<String>()
    
    // 2.
    subject
        .takeUntil(trigger)
        .subscribe(onNext: {
            print($0)
        })
        .disposed(by: bag)
    // 3.
    subject.onNext("A")
    subject.onNext("B")
    trigger.onNext("1") // 触发序列终止源序列
    subject.onNext("C")
    // 输出：A B
    // 思考：是不是可以通过 takeUntil 监控 VC 的销毁。
}

/// 1. distinctUntilChanged : 阻止下一个重复元素
/// 只阻止相邻重复元素。
example(of: "distinctUntilChanged") {
    let bag = DisposeBag()
    
    Observable.of("A", "A", "B", "B", "A")
        .distinctUntilChanged()
        .subscribe(onNext: {
            print($0)
        })
        .disposed(by: bag)
    // 输出：A B A
}

/// 2. distinctUntilChanged(_:) 自定义比较
example(of: "distinctUntilChanged(_:)") {
    let bag = DisposeBag()
    // 1
    let formatter = NumberFormatter()
    formatter.numberStyle = .spellOut // 朗读形式，英文，例如：110 ==> ["one", "hundred", "ten"]
    // 2. 序列
    Observable<NSNumber>.of(10, 110, 20, 200, 210, 310)
        // 3
        .distinctUntilChanged { a, b in
            guard let aWords = formatter.string(from: a)?.components(separatedBy: " "),
            let bWords = formatter.string(from: b)?.components(separatedBy: " ")
            else {return false}
            print(aWords, bWords)
            var containsMatch = false
            for aWord in aWords where bWords.contains(aWord) {
                containsMatch = true
                break
            }
            return containsMatch
            /*
             第一次：["ten"] ["one", "hundred", "ten"] ==> true, 跳过 110
             第二次：["ten"] ["twenty"] ==> false
             第三次：["twenty"] ["two", "hundred"] ==> false
             第四次：["two", "hundred"] ["two", "hundred", "ten"] ==> true，跳过 210
             第五次：["two", "hundred"] ["three", "hundred", "ten"] ==> true, 跳过 310
             */
            
        }
        // 订阅
        .subscribe(onNext: {
            print($0)
        })
        .disposed(by: bag)
}