# 如何使用RxSwift(進階)

接下來我們將探討一些 RxSwift 的高級用法，包括一些高階操作符和技巧。

1. `debounce`：這個操作符對於處理高頻率事件，例如用戶在搜索框中輸入時，非常有用。它可以幫助您減少事件處理的頻率，避免對每個輸入進行處理。

let searchTextField = UITextField()

searchTextField.rx.text.orEmpty
    .debounce(.milliseconds(300), scheduler: MainScheduler.instance)
    .subscribe(onNext: { searchText in
        print("Search text: \(searchText)")
    }).disposed(by: disposeBag)

2. `distinctUntilChanged`：此操作符可確保僅在序列的當前元素與前一個元素不同時發出元素。這在減少不必要的處理和更新時非常有用。

searchTextField.rx.text.orEmpty
    .distinctUntilChanged()
    .subscribe(onNext: { searchText in
        print("Search text: \(searchText)")
    }).disposed(by: disposeBag)

3. `switchLatest`：當您處理多個可觀察序列時，這個操作符可以幫助您始終關注最新的序列。

let first = PublishSubject<String>()
let second = PublishSubject<String>()
let activeObservable = BehaviorSubject(value: first as Observable<String>)

activeObservable.switchLatest()
    .subscribe(onNext: { value in
        print("Latest value: \(value)")
    }).disposed(by: disposeBag)

first.onNext("Hello from first")
second.onNext("Hello from second")
activeObservable.onNext(second)
first.onNext("Hello again from first")
second.onNext("Hello again from second")

4. 使用`Driver`：`Driver` 是 RxSwift 的一個特性，可確保在主綫程中觀察和處理 UI 事件，同時避免産生錯誤。

let searchDriver = searchTextField.rx.text.orEmpty
    .debounce(.milliseconds(300), scheduler: MainScheduler.instance)
    .distinctUntilChanged()
    .asDriver(onErrorJustReturn: "")

searchDriver.drive(onNext: { searchText in
    print("Search text: \(searchText)")
}).disposed(by: disposeBag)

5. 錯誤處理：RxSwift 提供了一些操作符，如 `catch` 和 `retry` ，以幫助您處理錯誤。

func loadText(from url: URL) -> Observable<String> {
    return Observable.create { observer in
        // Assume this function loads text from a URL and can throw errors
        do {
            let text = try String(contentsOf: url)
            observer.onNext(text)
            observer.onCompleted()
        } catch {
            observer.onError(error)
        }
        return Disposables.create()
    }
}

let url = URL(string: "https://example.com")!
loadText(from: url)
    .catch { error in
        return Observable.just("Failed to load text: \(error.localizedDescription)")
    }
    .subscribe(onNext: { text in
        print("Loaded text: \(text)")
    }).disposed(by: disposeBag)

6. `throttle`：與 `debounce` 類似，`throttle` 操作符也用於減少事件處理的頻率，但它的工作方式略有不同。在指定的時間段內，`throttle` 僅允許首個事件通過，而 `debounce` 則允許最後一個事件通過。

searchTextField.rx.text.orEmpty
    .throttle(.milliseconds(300), scheduler: MainScheduler.instance)
    .subscribe(onNext: { searchText in
        print("Search text: \(searchText)")
    }).disposed(by: disposeBag)

7. `share`：當您希望多個觀察者訂閱同一個 Observable 時，可以使用 share 操作符。這可以減少重復的工作和資源使用。

let sharedObservable = loadText(from: url).share()

sharedObservable.subscribe(onNext: { text in
    print("First observer: \(text)")
}).disposed(by: disposeBag)

sharedObservable.subscribe(onNext: { text in
    print("Second observer: \(text)")
}).disposed(by: disposeBag)

8. `startWith`：此操作符可以讓您在 Observable 序列的開始插入一個或多個事件。

Observable.from([1, 2, 3, 4, 5])
    .startWith(0)
    .subscribe(onNext: { value in
        print("Value: \(value)")
    }).disposed(by: disposeBag)

9. `zip`：使用 `zip` 操作符，您可以將多個 Observable 的事件組合在一起，形成一個新的Observable 序列。它按照事件發生的順序將不同 Observable 中的事件組合起來。

let first = PublishSubject<String>()
let second = PublishSubject<String>()

Observable.zip(first, second) { (firstValue, secondValue) in
    return "First: \(firstValue), Second: \(secondValue)"
}.subscribe(onNext: { value in
    print("Zipped value: \(value)")
}).disposed(by: disposeBag)

first.onNext("Hello from first")
second.onNext("Hello from second")
first.onNext("Hello again from first")
second.onNext("Hello again from second")

10. `observeOn`和 `subscribeOn`：當您想要更改處理事件和訂閱事件的線程時，可以使用這些操作符。

let backgroundScheduler = ConcurrentDispatchQueueScheduler(qos: .background)

Observable.from([1, 2, 3, 4, 5])
    .subscribeOn(backgroundScheduler)
    .map { $0 * 2 }
    .observeOn(MainScheduler.instance)
    .subscribe(onNext: { value in
        print("Doubled value: \(value)")
    }).disposed(by: disposeBag)

---

****這些只是 RxSwift 中許多操作符和技巧的一部分。要更深入地學習 RxSwift，您可以參考官方文檔、示例、教程以及社區資源。這些資源將幫助您更好地理解響應式編程，並提高您在實際項目中使用 RxSwift 的技能。****

參考文件：
https://github.com/ReactiveX/RxSwift
https://beeth0ven.github.io/RxSwift-Chinese-Documentation/