2回答
我有一个结构Test，我想实现轮询function的std::future::Future use std::{ pin::Pin,};
async fn function(&mut self) {}
浏览 30提问于2020-04-19得票数 5
回答已采纳
我想实现一个基于FuturesUnordered的Stream，它同样应该计算返回类型为Result<SomeEnum>的async函数，不过为了简单起见，我们假设它只是一个Result<f64>。当async fns最终返回Futures时，我假设我必须用以下方式来定义我的结构： use anyhow::Result; }
} 我现在遇
浏览 20提问于2021-04-27得票数 1
回答已采纳
最近，我开始使用Rust中的异步流，我一直发现自己处于这样的情况:我想在Stream的实现中使用异步函数。Future;
fn bar(self) -> Box<dyn Future<Output = String>>;对于String的情况，它就像您所期望的那样工作我可以理解为什么这是一个问题，并且我理解asy
浏览 1提问于2020-10-05得票数 1
回答已采纳
这些天，我正在处理Rust的异步生态系统，特别是流，我想实现一个等价的map()方法(来自StreamExt)，有些特性在这里并不有趣。我的代码看起来是这样的(我简化了fn_to_future函数)： }我知道我的问题有几
浏览 1提问于2021-11-01得票数 2
回答已采纳
函数是“推送”数据，我不能将函数(这是这个问题的整个前提)更改为使用异步流或其他类型的轮询。
目前，我被迫使用&mut Vec (它实现了io::Write)来缓冲整个结果，然后发送Vec作为响应体。但是，响应可能很大，所以我宁愿在没有缓冲的情况下对其进行流处理。是否有某种适配器可以实现io::Write，在响应背压时需要写入阻塞，并且与actix可以用于响应的类型(例如futures::Stream)兼容？
浏览 0提问于2019-04-16得票数 2
回答已采纳
我尝试使用来自流的消息，同时处理来自REST服务调用的async响应。我已经用一个模拟流和未来举例说明了该程序的结构： use tokio::runtime;
use futures::stream::{self, StreamExt};
let mut s = stream::repeat::<u32>(9);
浏览 10提问于2021-03-31得票数 1
这个MWE演示了tokio::spawn在for in循环中的使用。注释的代码sleepy_futures.push(sleepy.sleep_n(2));运行良好，但不运行/轮询异步函数。基本上，我想同时运行一系列异步函数。我很乐意更改Sleepy的实现或使用另一种库/技术。pub struct Sleepy; pub async fn sleep_n(self: &S
浏览 4提问于2020-08-10得票数 5
回答已采纳
我正在试验如何使用Rust的tokio来停止异步TCP连接和数据包读取。我已经编写了一种在CTRL+C上停止循环或使用channel和select停止超时事件的方法，但是循环中的select会发生移动，但它无法编译。_ = &shutdown => return None Future Future不是为&tokio::sync::oneshot::Receiver<()>实现的。是
浏览 8提问于2022-03-18得票数 1
我正在使用actix，并且试图在闭包中返回一个异步函数，但是我得到了以下错误：137 | | ...我尝试过将变量移出移动块，并尝试将它们放置在不同的地方，但都没有成功。error[E0525]: expected a closure
浏览 2提问于2021-11-27得票数 0
回答已采纳
1回答
我试图编写一个函数，该函数从服务器读取响应，并返回等待时应该返回实现tokio AsyncRead特性的未来流：我不知道如何从futures::stream::Stream返回的迭代器创建一个peers.array_chunks().map(|x: &[u8这个显示这样的事情是可
浏览 1提问于2022-09-04得票数 1
回答已采纳
通过async谓词进行过滤--“容易”的方式let arr = vec!在这种情况下，我们的电话看起来就像： .awaitfn by_length(min_length: usize) -> impl Fn
浏览 8提问于2022-02-03得票数 4
回答已采纳
我发现很难理解为什么以及何时需要显式地对传递给对象上的poll方法的Context和/或其Waker执行某些操作，我正在为该对象实现Future。use std::{future::Future, pin::Pin, task::{Context, Poll}, time::Duration};use tokio::sync::mpsc; /&
浏览 25提问于2021-02-11得票数 1
回答已采纳
1回答
在未来实现中手动轮询流
、、、
我正在迁移到futures 0.3和tokio 0.2的过程中，有一种反复出现的模式我无法重复使用。我不确定这种模式是否过时了，或者我是否对Pin做错了什么。此类结构的Future实现包括反复轮询流，直到它们返回Pending ( 0.1生态系统中的NotReady)。然而，在未来0.3中，Future::poll和Stream::poll_next采用self而不是&mut self，这种模式不再有效：
use future
浏览 1提问于2019-08-17得票数 3
回答已采纳
1回答
未来的睡眠:调查
、、、、
据我所知，我正试图为来自crossterm机箱的输入创建一个未来的轮询，据我所知，它不提供异步API。但很明显，程序一直都在使用100%的CPU，因为执行者总是试图轮询未来，以防出现新的情况。因此，我想添加一些相当于睡眠的异步代码，这将在执行程序下次尝试轮询未来时延迟，因此我尝试添加以下内容(在返回Poll::Pending之前)，这显然不起作用，因为sleep_future::poll()找到一种
浏览 7提问于2022-10-24得票数 0
回答已采纳
我想编写一个异步函数，它反复从web轮询一个资源，并在它准备好时返回。我正在使用实现它 // do other worksfuture::poll_fn(|ctx| match poll_web_resource
浏览 0提问于2019-08-12得票数 2
回答已采纳
目前，我们正在切换的API网关引擎，由c到tokio，超级，锈锈。
下面是我所想到的流程:当收到一个具有较大正文大小的POST请求时，所有http主体在读取到内容长度后都会读取→，然后执行传递给make_service_fn的未来代码(示例中的回显操作)。但是，一旦收到请求，就会执行传递给make_ser
浏览 2提问于2022-05-16得票数 2
回答已采纳
我使用async_trait机箱来定义一个特征上的async方法。我打算将它返回的Future转换为Stream，将Stream包装在Arc中，并将Arc发送到多个线程。tokio::runtime::Runtime;
trait Trait: Send + Sync {}
async fn use_trait<T: Trait>
浏览 0提问于2021-01-27得票数 4
5回答
它似乎是按顺序返回结果，但期货是同时执行的。let tasks = vec!FutureResult<_, _>, futures::FutureResult<(), _>, [closure@src/main.rs:10:34: 10:42 task:_]>`
我可能走错路了，但我的想法已经用完了
浏览 3提问于2018-01-03得票数 8
回答已采纳
下面是我尝试过的代码(使用fold()实现流的len()，但有一些奇怪的类型错误我无法理解(do(row: Row)返回一个Result<(), Error>)： let rows_count = rows.for_each(|row| parse_row(&row)) .wait()
浏览 10提问于2019-01-25得票数 0
1回答
我对Rust和它的异步/等待模型非常陌生，我正在尝试做一些看起来像专门的Haskell traverse函数的事情。给定一个Vec<T>和一个函数T -> Future<Output = R>，我想得到一个Future<Output = Vec<R>>。目前，我有以下几点：
pub async fn traverse<I, T
浏览 0提问于2020-05-24得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
