update ch17-04

src/ch17-04-streams.md

@@ -4,11 +4,11 @@
 > <br>
 > commit f04d20fe8d1a49c3bffa10a3086c58e527ff0a90
 
-到本章的目前为止，我们大部分时间停留在独立的 future 上。一个大的例外就是我们用过的异步信道。回忆一下在本章之前的 [“消息传递”][17-02-messages] 中我们如何使用的异步信道的。异步 `recv` 方法随着时间的推移产生一个序列的项。这是一个通用的多的模式的实例，通常被称为 *流*（*stream*）。
+到本章的目前为止，我们大部分时间停留在独立的 future 上。一个重要的例外就是我们用过的异步信道。回忆一下在本章之前的 [“消息传递”][17-02-messages] 中我们如何使用异步信道接收端的。异步 `recv` 方法随着时间的推移产生一个序列的项。这是一个通用的多的模式的实例，通常被称为 *流*（*stream*）。
 
-一个序列的项是我们之前是见过的，回忆一下第十三章的 `Iterator` trait，不过迭代器和异步信道接收端有两个区别。第一个区别是时间元素：迭代器是同步的，而信道接收端是异步的。第二个区别是 API。当直接处理 `Iterator` 时，我们会调用其 `next` 方法。对于这个特定的 `trpl::Receiver` 流，我们调用一个异步的 `recv` 方法，不过这些 API 看起来非常相似。
+一个序列的项是我们之前是见过的，回忆一下第十三章的 `Iterator` trait，不过迭代器和异步信道接收端有两个区别。第一个区别是时间的维度：迭代器是同步的，而信道接收端是异步的。第二个区别是 API。当直接处理 `Iterator` 时，我们会调用其同步 `next` 方法。对于这个特定的 `trpl::Receiver` 流，我们调用一个异步的 `recv` 方法。不过这两个 API 看起来非常相似。
 
-这种相似性并不是巧合。流类似于一种异步形式的迭代器。不过鉴于 `trpl::Receiver` 专门等待接收消息，多用途的流 API 则更为通用：它像 `Iterator` 一样提供了下一个项，不过是异步版本的。Rust 中迭代器和流的相似性意味着我们实际上可以从任何迭代器上创建流。就迭代器而言，可以通过调用其 `next` 方法并 await 输出来使用流，如示例 17-30 所示。
+这种相似性并非巧合。流类似于一种异步形式的迭代器。不过鉴于 `trpl::Receiver` 专门等待接收消息，多用途的流 API 则更为通用：它像 `Iterator` 一样提供了下一个项，不过是异步版本的。Rust 中迭代器和流的相似性意味着我们实际上可以从任何迭代器上创建流。就迭代器而言，可以通过调用其 `next` 方法并 await 输出来使用流，如示例 17-30 所示。
 
 <figure class="listing">
 
@@ -22,9 +22,9 @@
 
 </figure>
 
-我们以一组数字作为开始，将其转换为一个迭代器并接着调用 `map` 将其所有值翻倍。然后使用 `trpl::stream_from_iter` 函数将迭代器转换为流。再然后在 `while let` 循环中到达时循环流中的项。
+我们以一组数字作为开始，将其转换为一个迭代器并接着调用 `map` 将其所有值翻倍。然后使用 `trpl::stream_from_iter` 函数将迭代器转换为流。再然后在 `while let` 循环中到达时循环处理流中的项。
 
-不幸的是当我们尝试运行代码时，它不能编译。相反如果我们观察其输出，它会报告没有可用的 `next` 方法。
+不幸的是当我们尝试运行代码时，代码无法编译。相反如果我们观察其输出，它会报告没有可用的 `next` 方法。
 
 <!-- manual-regeneration
 cd listings/ch17-async-await/listing-17-30
@@ -76,4 +76,40 @@ help: there is a method `try_next` with a similar name
 
 </figure>
 
+将所有这些代码片段拼凑在一起，这段代码如我们预期般运行！更重要的是，现在我们在作用域中拥有 `StreamExt`，就可以使用所有其工具方法。例如在示例 17-32 中，我们使用 `filter` 方法来过滤掉所有不是 3 或者 5 的倍数的项。
+
+<figure class="listing">
+
+<span class="file-name">文件名：src/main.rs</span>
+
+```rust
+{{#rustdoc_include ../listings/ch17-async-await/listing-17-32/src/main.rs:all}}
+```
+
+<figcaption>示例 17-32：使用 `StreamExt::filter` 方法来过滤 `Stream`</figcaption>
+
+</figure>
+
+当然这并不是非常的有趣。我们完全可以使用普通的迭代器而不用任何异步操作来做到这些。所以让我们看看一些其它的只能用流的内容。
+
+### 组合流
+
+很多概念天然地可以用流来代表：队列中可用的项；或者处理超过计算机内存的数据，一次只能从文件系统拉取一个块；或者通过网络随着时间推移到达的数据。因为流是 future，我们也可以将其用于任何其它类型的 future，并且我们可以用一种非常有趣的方式来组合它们。例如，我们可以批量处理事件来避免触发过多的网络调用，为一系列的长时间运行的任务设置超时，或者对用户接口事件限速来避免进行无尽的工作。
+
+让我们构建一个小的消息流作为开始，将其作为一个可能从 WebSocket 或者其它现实世界中的通信协议中遇到的数据流的替代。在示例 17-33 中，我们创建了一个返回 `impl Stream<Item = String>` 的 `get_messages` 函数。作为其实现，我们创建了一个异步信道，循环英文字母表的前是个字符，并通过信道发送它们。
+
+我们还使用了一个新类型：`ReceiverStream`，它将 `trpl::channel` 的 `rx` 接收端转换为一个带有带有 `next` 方法的 `Stream`。回到 `main`，我们使用了一个 `while let` 循环来打印来自流中的所有消息。
+
+<figure class="listing">
+
+<span class="file-name">文件名：src/main.rs</span>
+
+```rust
+{{#rustdoc_include ../listings/ch17-async-await/listing-17-33/src/main.rs:all}}
+```
+
+<figcaption>示例 17-33：使用 `rx` 接收端作为一个 `ReceiverStream`</figcaption>
+
+</figure>
+
 [17-02-messages]: ch17-02-concurrency-with-async.html#消息传递