Day18 Combine 05 - Operators 类型介绍 : 转换操作符

转换操作符

map/mapError

map操作符会执行给定的闭包，将上游发布的内容进行转换，然後再发送给下游订阅者，mapError则将错误转换为另外一种错误类型

[1, 2].publisher
    .map { $0.description + "test" }
    .sink(receiveValue: { value in
        print(value)
    })

flatMap

flatMap 操作符会转换上游发布者发送的所有的元素，然後返回一个新的或者已有的发布者。

flatMap 会将所有返回的发布者的输出合并到一个输出流中。我们可以通过 flatMap 操作符的 maxPublishers 参数指定返回的发布者的最大数量

class TestObservableObject: ObservableObject {
    var cancellable: AnyCancellable?
    
    struct Student: Decodable {
        let name: String
    }

    let json = """
    [{
    "name": "Ryder"
    },
    {
    "name": "Jason"
    },
    {
    "name": "Ray"
    }]
    """
    
    init() {
        let publisher = PassthroughSubject<String, Never>()
        
        cancellable = publisher
            .flatMap { value in
                Just(value.data(using: .utf8)!)
                    .decode(type: [Student].self, decoder: JSONDecoder())
                    .catch { _ in
                        Just([Student(name: "errorName")])
                    }
            }
            .sink(receiveCompletion: { _ in
                print("finished")
            }, receiveValue: { someValue in
                print(someValue)
            })
        
        publisher.send(json)
    }
}

因为flatMap闭包要求的返回值必须是一个publisher，所以在上边的程序码中，我们使用了Just，它把 json资料对映成阵列。

在上边的catch中也用到了Just，目的是当发生错误时，返回一个预设的值，值得注意的是，catch同样要求返回一个publsiher

scan

scan将收到的值与当前的值，按照给定的closure 进行转换

(1...3).publisher
    .scan(3, +)
    .sink(receiveValue: { value in
        print(value)
    })
/*印出 
4
6
9
*/