|
|
@ -115,7 +115,7 @@ help: there is a method `try_next` with a similar name
|
|
|
|
|
|
|
|
|
|
|
|
首先,我们创建了一个返回 `impl Stream<Item = String>` 的 `get_messages` 函数。作为其实现,我们创建了一个异步信道,循环遍历英文字母表的前 10 个字母,并通过信道发送它们。
|
|
|
|
首先,我们创建了一个返回 `impl Stream<Item = String>` 的 `get_messages` 函数。作为其实现,我们创建了一个异步信道,循环遍历英文字母表的前 10 个字母,并通过信道发送它们。
|
|
|
|
|
|
|
|
|
|
|
|
我们还使用了一个新类型:`ReceiverStream`,它将 `trpl::channel` 的 `rx` 接收端转换为一个带有带有 `next` 方法的 `Stream`。回到 `main`,我们使用了一个 `while let` 循环来打印来自流中的所有消息。
|
|
|
|
我们还使用了一个新类型:`ReceiverStream`,它将 `trpl::channel` 的 `rx` 接收端转换为一个带有 `next` 方法的 `Stream`。回到 `main`,我们使用了一个 `while let` 循环来打印来自流中的所有消息。
|
|
|
|
|
|
|
|
|
|
|
|
运行这段代码时,我们将得到与预期完全一致的结果:
|
|
|
|
运行这段代码时,我们将得到与预期完全一致的结果:
|
|
|
|
|
|
|
|
|
|
|
|