advance/async/async-await

[giscus[bot]]

advance/async/async-await

https://course.rs/advance/async/async-await.html

[SuanCaiYv]

越来越复杂了呀！尤其和生命周期混在一起之后🥺

[pphboy]

我也看不懂

[amesy]

导入模块
use futures::channel::mpsc;
use futures::{executor::block_on, SinkExt, StreamExt};

[cctga]

嗯，注意和 std::sync::mpsc::channel 做区分

[lnb-wxqy]

这节讲的感觉有点粗啊

[xiandaoyan]

while let Some(item) = stream.try_next().await? 这里的问号?是啥啊？ 这语言语法真的太难了。。。。

[kelvinschen]

https://doc.rust-lang.org/reference/expressions/operator-expr.html#the-question-mark-operator

[zcgzxg]

一个参数的类型要写这么长

mut stream: Pin<&mut dyn Stream<Item = Result<u8, io::Error>>>

[jeferwang]

看到Pin就头大，里面还带个dyn

[upWooStream]

方法入参定义也是支持这么写的吗？mut在变量前：
mut stream: Pin<&mut dyn Stream<Item = i32>>

[carzpurzkey]

这个好像是说实参所有权被转移到了函数内，并且无视实参原可变性，现在一律为可变的。前面有个章节有个大神回答过这个问题，忘记是哪章了…

[Ray-lyy]

越来越复杂了，从async入门第一节开始，我得看好久才能勉强似乎看明白，对着示例敲，搞不定的问ai，这块以后要是用到了只能说道阻且长长长长长啊

[Raine-Yang-UofT]

建议最后一个例子了最好把jump_n_times和report_n_jumps换成什么调用标准库函数的操作。我一开始以为这两个函数是标准库里的函数，还在网上查半天找不到，然后才反应过来应该是自定义的函数

[lixiaowei11111]

没太看懂这一句话是什么意思:意味着 async fn 函数返回的 Future 必须满足以下条件: 当 x 依然有效时， 该 Future 就必须继续等待( .await ),
不应该是在必须在x有效时,才能进行继续等待的意思吗,是反了吗
原文"This means that the future returned from an async fn must be .awaited while its non-'static arguments are still valid. In the common case of .awaiting the future immediately after calling the function (as in foo(&x).await) this is not an issue.

[Boysunshiny]

有意思，现在所有的东西都综合起来了，要细想

[juilletVent]

没看明白，Stream流不是针对单个资源的吗？比如文件流、音视频流、网络数据流，这种流对顺序是有要求的，需要串行处理才对呀，没法并行吧。

对于独立的单个事件、客户端请求、DB这种确实是可以并发执行，这里的Stream是指对这些场景的抽象？把这些抽象成流进行处理吗？emmm，看不懂了....😂😂