RxSwift学习入门——Observable的操作符

IOS

2023-12-23 17:04:44

流水线与Observable

流水线就是一个将原材料一步步加工成成品的过程，在这个过程中可能需要多个流水线协调工作。为了保证生产效率，需要通过阻挡器来协调不同流水线上的运输节奏，同时还需要剔除掉原材料中的不良品。

类似的，在RxSwift中，我们可以将Observable看作是一个流水线，它可以将数据源源不断的传输到订阅者。而操作符就相当于流水线上的一系列加工步骤，它们可以对数据进行各种各样的处理，最终将数据传输给订阅者。

操作符的分类

RxSwift中的操作符种类繁多，根据其功能，可以大致分为以下几类：

创建操作符：用于创建Observable对象，例如from、just、of等。
转换操作符：用于对Observable中的数据进行转换，例如map、filter、reduce等。
组合操作符：用于将多个Observable组合在一起，例如merge、concat、zip等。
错误处理操作符：用于处理Observable中可能出现的错误，例如catchError、retry、timeout等。
调度操作符：用于指定Observable在哪个线程上执行，例如subscribeOn、observeOn等。

操作符的实例

下面我们通过一个简单的实例来说明操作符的使用方法。假设我们有一个Observable对象，它发射了一个包含1、2、3、4、5的整数序列。我们想要对这个序列进行如下处理：

将每个数字加1。
过滤掉所有大于3的数字。
将剩下的数字求和。

我们可以使用以下代码来实现：

Observable.of(1, 2, 3, 4, 5)
    .map { $0 + 1 }
    .filter { $0 <= 3 }
    .reduce(0, accumulator: +)
    .subscribe(onNext: { print($0) })

这段代码首先使用map操作符将每个数字加1，然后使用filter操作符过滤掉所有大于3的数字，最后使用reduce操作符将剩下的数字求和。最后，我们使用subscribe方法来订阅Observable，以便在数据到达时收到通知。

深入理解操作符

为了更深入地理解操作符，我们来看看map操作符的原理。map操作符的作用是对Observable中的每个元素应用一个转换函数，并将转换后的结果作为新的Observable发射出去。

map操作符的语法如下：

public func map<T>(_ transform: @escaping (E) throws -> T) -> Observable<T>

其中，E是输入Observable元素的类型，T是输出Observable元素的类型。transform是转换函数，它接受一个E类型的元素作为输入，并返回一个T类型的元素作为输出。

map操作符的实现方式如下：

public func map<T>(_ transform: @escaping (E) throws -> T) -> Observable<T> {
    return Observable<T>.create { observer in
        let subscription = self.subscribe { event in
            switch event {
            case .next(let element):
                do {
                    let transformedElement = try transform(element)
                    observer.on(.next(transformedElement))
                } catch {
                    observer.on(.error(error))
                }
            case .error(let error):
                observer.on(.error(error))
            case .completed:
                observer.on(.completed)
            }
        }
        return Disposables.create {
            subscription.dispose()
        }
    }
}