[移动开发]Combine操作符append和prepend

swift标准库中有append函数，可以在数组或字符串后添加一个相同类型的数据，比如

var str = "Hello"
str.append(" world!")
// Output
Hello world!

在Combi个ine中，也可以使用append来给Publisher在后面增加一个Output，或者增加一个Publisher，同时，Combine还提供了一个prepend操作符，和append相反，他是在前面增加一个Output，或是publisher

prepend Output

比如我们在playground中实现如下代码

// Combine
var subscriptions = Set<AnyCancellable>()

// prepend 一个Output
func prependOutputExample() {
    let stringPublisher = ["World!"].publisher

    stringPublisher
        .prepend("Hello")
        .sink(receiveValue: { print($0) })
        .store(in: &subscriptions)
}

prependOutputExample()

// Output
Hello
World!

stringPublisher本身的Output是字符串“World!”，经过prepend操作符处理后，他变成了

[ "Hello", "World!"]

所以sink接收时，会接收到两次数据，分别是“Hello”和“World!”。

将上面代码改成append后，会变成在后面添加Hello，就不再用代码举例了。

prepend Publisher

// prepend 一个Publisher
func prependPublisherExample() {
    let subject = PassthroughSubject<String, Never>()
    let stringPublisher = ["Break things!"].publisher

    stringPublisher
        .prepend(subject)
        .sink(receiveValue: { print($0) })
        .store(in: &subscriptions)

    subject.send("Run code")
    subject.send(completion: .finished)
}

prependPublisherExample()

// Output
Run code
Break things!

stringPublisher是一个字符串数组的publisher

subject是Output类型为String的publisher，也可以说是subject，因为subject也是实现了publisher协议的一个类型，他有一个特殊的方法是send，可以通过send来手动发布数据。

在stringPublisher被订阅前，用prepend将subject挂接在stringPublisher的前面，这时候publisher的类型变为了

Publishers.Concatenate<PassthroughSubject<String, Never>, Publishers.Sequence<[String], Never>>

Publishers.Concatenate的定义是

A publisher that emits all of one publisher’s elements before those from another publisher.

在来自另一个发布者的元素之前发布一个发布者的所有元素的发布者。?

所以在之后的sink中，我们依次接收到了两个publisher的Output数据，也就是Run code和Break things!

append操作符也是同样，只不过位置和prepend相反，一个在前，一个在后。

实际应用?

在实际应用中，可以用在"拼接两个网络请求"的场景，比如我们有两个需要获取的网络数据，分别来自

http://jsonplaceholder.typicode.com/posts/1

json内容为

{
  "userId": 1,
  "id": 1,
  "title": "sunt aut facere repellat provident occaecati excepturi optio reprehenderit",
  "body": "quia et suscipit\nsuscipit recusandae consequuntur expedita et cum\nreprehenderit molestiae ut ut quas totam\nnostrum rerum est autem sunt rem eveniet architecto"
}

和?http://jsonplaceholder.typicode.com/posts/2?

json内容为

{
  "userId": 1,
  "id": 2,
  "title": "qui est esse",
  "body": "est rerum tempore vitae\nsequi sint nihil reprehenderit dolor beatae ea dolores neque\nfugiat blanditiis voluptate porro vel nihil molestiae ut reiciendis\nqui aperiam non debitis possimus qui neque nisi nulla"
}

我们需要同时处理两个请求的返回值时，可以使用prepend或append操作符

在playground下使用如下代码：

// 1
struct TestData: Codable {
    var userId: Int
    var id: Int
    var title: String
    var body: String
    
    init(userId: Int = 0, id: Int = 0, title: String = "", body: String = "") {
        self.userId = userId
        self.id = id
        self.title = title
        self.body = body
    }
}

// 2
let url1 = URL(string: "http://jsonplaceholder.typicode.com/posts/1")!
let url2 = URL(string: "http://jsonplaceholder.typicode.com/posts/2")!

// 3
func getData1() -> AnyPublisher<TestData, Never> {
    
    return URLSession.shared.dataTaskPublisher(for: url1)
        .map { $0.data }
        .decode(type: TestData.self, decoder: JSONDecoder())
        .replaceError(with: TestData())
        .eraseToAnyPublisher()
}

// 4
func getData2() -> AnyPublisher<TestData, Never> {
    
    return URLSession.shared.dataTaskPublisher(for: url2)
        .map { $0.data }
        .decode(type: TestData.self, decoder: JSONDecoder())
        .replaceError(with: TestData())
        .eraseToAnyPublisher()
}


// 5
func sinkData() {
    
    let pub = getData1()
    pub
        .append(getData2())
        //.prepend(getData2())
        .sink { print("sinkData: \($0)") }
        .store(in: &subscriptions)
}

sinkData()

1、创建JSON返回的数据结构

2、创建两个请求的URL

3、创建获取第一个数据请求的publisher（函数返回值）

4、创建获取第二个数据请求的publisher（函数返回值）

5、同时处理两个数据请求，使用append(getData2())时，打印结果是

sinkData: TestData(userId: 1, id: 1, title: "sunt aut facere repellat provident occaecati excepturi optio reprehenderit", body: "quia et suscipit\nsuscipit recusandae consequuntur expedita et cum\nreprehenderit molestiae ut ut quas totam\nnostrum rerum est autem sunt rem eveniet architecto")

sinkData: TestData(userId: 1, id: 2, title: "qui est esse", body: "est rerum tempore vitae\nsequi sint nihil reprehenderit dolor beatae ea dolores neque\nfugiat blanditiis voluptate porro vel nihil molestiae ut reiciendis\nqui aperiam non debitis possimus qui neque nisi nulla")

可以看出来是先处理了第一个数据请求，再处理第二个数据请求，因为append是在后面添加。

注释掉append行，将prepend行取消注释，打印结果为

sinkData: TestData(userId: 1, id: 2, title: "qui est esse", body: "est rerum tempore vitae\nsequi sint nihil reprehenderit dolor beatae ea dolores neque\nfugiat blanditiis voluptate porro vel nihil molestiae ut reiciendis\nqui aperiam non debitis possimus qui neque nisi nulla")

sinkData: TestData(userId: 1, id: 1, title: "sunt aut facere repellat provident occaecati excepturi optio reprehenderit", body: "quia et suscipit\nsuscipit recusandae consequuntur expedita et cum\nreprehenderit molestiae ut ut quas totam\nnostrum rerum est autem sunt rem eveniet architecto")

先处理了第二个数据请求，再处理第一个数据请求，因为prepend是在前面添加。?

有一点要注意，prepend和append，要求被挂接的Output或publisher，与原publisher的Output类型要相同。对于我们最后一个网络请求的例子，因为两个请求返回的json数据格式是一样的，所以可以用prepend或append来实现。如果json数据格式不一样，并且还需要同时处理的话，则需要使用zip、merge或是combineLeast来实现。