Hello ReactiveSwift(2): 示例：在线搜索

2017-05-05 本文已影响194人 Jorn丶Wu

官方文档：
http://reactivecocoa.io/reactiveswift/docs/latest/index.html
实战项目：
https://github.com/JornWu/ZhiBo_Swift.git

<i>需求：假设你有一个TextField，并且每当用户输入内容时，你都希望创建一个搜索该查询的网络请求。</i>

1、观察文本编辑

第一步是监视该textfield的编辑，用到UITextField的专门用于该目的的RAC拓展：

let searchStrings = textField.reactive.continuousTextValues

这给我们一个发送值类型为String?的Signal

2、制作网络请求

对于每个字符串，我们要执行一个网络请求。ReactiveSwift提供了一个 URLSession扩展功能：

let searchResults = searchStrings
    .flatMap(.latest) { (query: String?) -> SignalProducer<(Data, URLResponse), AnyError> in
        let request = self.makeSearchRequest(escapedQuery: query)
        return URLSession.shared.reactive.data(with: request)
    }
    .map { (data, response) -> [SearchResult] in
        let string = String(data: data, encoding: .utf8)!
        return self.searchResults(fromJSONString: string)
    }
    .observe(on: UIScheduler())

这将String的制造器转变成包含搜索结果的Array制造器。且在主线程上进行（使用UISchedule）。此外，
flatMap(.latest)
这里确保只有一个搜索（最新的）被允许运行。如果用户在网络请求仍处于进行状态时键入另一个字符，则在启动新的搜索之前将被取消。试想想自己手动去实现将花费到少代码。

3、接受结果

由于搜索字符串的来源是具有热信号语义的Signal，我们应用的变换会自动进行推测每当任何时候新值从searchStrings发出时。
因此，我们可以使用Signal.observe(_:)简单地观察Signal：

searchResults.observe { event in
    switch event {
    case let .value(results):
        print("Search results: \(results)")

    case let .failed(error):
        print("Search error: \(error)")

    case .completed, .interrupted:
        break
    }
}

这里，只要打印到控制台，我们可以观察到包含我们的结果的Value，也可以很容易地通过其他操作。如在屏幕上更新tableView或label。

4、处理错误

目前为止在这个示例中，任何网络错误都将会产生一个Failed事件，这些事件将会终止事件流，不幸的是，这意味着以后的请求将不会被执行。
为了解决这个问题，我们需要决定如何处理发生的故障。最快的解决方案是记录它们，然后忽略它们：

.flatMap(.latest) { (query: String) -> SignalProducer<(Data, URLResponse), AnyError> in
        let request = self.makeSearchRequest(escapedQuery: query)

        return URLSession.shared.reactive
            .data(with: request)
            .flatMapError { error in
                print("Network error occurred: \(error)")
                return SignalProducer.empty
            }
    }

通过使用empty事件流来替代failures，我们可以有效地忽略它们。但在丢弃前，可能要做至少两次适当的尝试。简单的，有有个尝试操作恰好可以这样做。
我们优化的searchResults制造者可以看起来如下：

let searchResults = searchStrings
    .flatMap(.latest) { (query: String) -> SignalProducer<(Data, URLResponse), AnyError> in
        let request = self.makeSearchRequest(escapedQuery: query)

        return URLSession.shared.reactive
            .data(with: request)
            .retry(upTo: 2)
            .flatMapError { error in
                print("Network error occurred: \(error)")
                return SignalProducer.empty
            }
    }
    .map { (data, response) -> [SearchResult] in
        let string = String(data: data, encoding: .utf8)!
        return self.searchResults(fromJSONString: string)
    }
    .observe(on: UIScheduler())

5、节流请求

现在，假如你只想偶尔地真正执行搜索，一最小化流量。
ReactiveCocoa有一个声明的throttle运算符，我们可以应用于我们的搜索字符串：

let searchStrings = textField.reactive.continuousTextValues
    .throttle(0.5, on: QueueScheduler.main)

这可以阻止发送间隔不到0.5秒的值。
手动地这样实现将要求具有有效的状体，且最终代码会更难理解！使用ReactiveCocoa，我们可以只使用一个运算符将时间整合到我们的事件流中即可。

6、调试事件流

由于其本质，一个流的堆链可能有几十个帧，这通常使调试成为非常令人沮丧的活动，一种天真的调试方式，就是将流行注入副作用，就像这样：

let searchString = textField.reactive.continuousTextValues
    .throttle(0.5, on: QueueScheduler.main)
    .on(event: { print ($0) }) // the side effect

这将打印流的事件，同时保留原始流的行为。SignalProducer和Signal都提供logEvents操作，这将自动为您做到这一点：

let searchString = textField.reactive.continuousTextValues
    .throttle(0.5, on: QueueScheduler.main)
    .logEvents()

有关更多信息和预先的用法，请查看
Debugging Techniques 文档。