-
有什么方法可以创建异步流生成器,从而产生重复调用函数的结果?
我想构建一个收集天气更新并将其表示为流的程序。我想无限循环地调用<code>get_weather()</code>,在<strong> -
DCCP对Rust中的mio的支持
我正在做一个有关DCCP协议的分布式系统项目。因此,目标是使每个节点都能够通过DCCP协议与所有其他节 -
从异步Tokio代码中使用std :: sync :: Mutex
我正在使用基于异步/等待的Tokio和Rust 1.39.0实现功能。我了解在异步上下文中使用常规<code>Mutex</code>可能 -
在Tokio TcpStream上并发读写
我有一种情况,线程1写入套接字,线程2从套接字读取。我过去通过<code>split()</code>进行了此操作,它将 -
为什么带有async-await的Tokio 0.2.0-alpha服务器不能并行处理请求?
我正在尝试编写一个小型Web服务器,该服务器使用Tokio库返回延迟的响应。我一直在阅读0.2.0-alpha.6版本 -
为返回的结果指定错误类型(在SinkExt.with的上下文中)
我正在尝试使用<strong> SinkExt.with </strong>在发送之前转换数据包字节。这是一个最小的代码片段: <pre -
没有为`std :: result :: Result <reqwest :: Response,reqwest :: Error>`实现特性std :: future :: Future`
我正在尝试运行基本的<code>reqwest</code> <a href="https://github.com/seanmonstar/reqwest/blob/master/examples/simple.rs" rel="n -
为什么`tokio :: main`报告错误“处理时检测到循环”?
我正在使用Tokio和<code>async</code> / <code>.await</code>创建一个UDP服务器,可以在其中以异步方式接收和发送 -
如何在rust / tokio中的TCP客户端绑定()?
我需要确保TCP连接的客户端通过特定的(IP)接口。标准方法是在<code>bind()</code>之前将<code>IP:0</code>的套 -
将AsyncRead转换为TryStream字节的最佳方法是什么?
我有一个<code> // Determine the Namespace referenced by the current context in the // kubeconfig file. namespace := "d -
如何从期货0.1组合器方法链中早日返回?
是否有办法从未来的合并者链中尽早返回?例如,如果某些条件成立,我想返回成功,否则继续沿链前 -
如何使用Tokio从子进程的stdout和stderr异步读取?
Tokio(我使用的是0.2,期货是0.3)具有<code>process::Command.output()</code>,它在完成后从子进程返回组合输出 -
异步fn中的返回类型错误:期望(),在枚举std :: result :: Result中找到
我写了一个简单的方法来查看按顺序返回Tokio的<code>DelayQueue</code>中的项目。 <code>DelayQueue</code>具有方法< -
Rust期货0.1版本。如何在非异步功能中等待异步?
我正在使用Rust未来的旧版本0.1。(无法升级..) 在Func A. poll_complete中调用Func B. <br/> 函数B是包装 -
如何以异步方式在rust中列出超过1000个aws-s3对象?
我有一个aws-s3存储桶,其中包含20000个以上的对象,我想要所有对象的名称。 但是aws会返回1000个批次的 -
受约束的特征`tokio :: net :: tcp :: stream :: TcpStream:tokio_io :: async_read :: AsyncRead`不满意
我无法编译一个简单的应用程序来测试tokio编解码器。 tokio :: net :: tcp :: stream :: TcpStream实现AsyncRead和-Writ -
与tokio同步调用异步函数
我一直在寻找文档,以找到一种同步调用异步函数的方法。具体来说,我正在尝试从<code>tokio::sync::mutex:: -
如何固定RefCell的内容?
我有一个结构<strong> MyAsyncStream </strong>和它的tokio :: io :: AsyncWrite实现: <pre><code>impl<S: AsyncRead + Asyn -
如何解决“线程'主'在'无电流反应器'中惊慌'的错误?
我正在尝试连接到数据库: <pre><code>extern crate tokio; // 0.2.6, features = ["full"] extern crate tokio_postgre -
Rust单元测试中的错误:“函数声明中缺少async关键字”
我正在使用tokio 0.2.6和Futures 0.3.0的Rust工作区中,尝试编译此代码时出现以下错误: <pre><code>#[cfg(test) -
无法在异步锈蚀任务中释放动态内存
我们的Rust应用程序似乎存在内存泄漏,我将问题简化为下面的代码示例。我仍然看不到问题出在哪里。< -
tokio-rs文档示例未编译
我正在尝试通过阅读其站点上的文档来学习tokio-rs,但是示例<a href="https://tokio.rs/docs/io/reading_writing_data/" -
Tokio运行时当前未运行时,“线程'main'感到恐慌” 解决方案:
我正在使用弹性搜索的博客文章中有关其新包装箱的示例代码,但无法使其按预期工作。 <code>thread 'm -
为什么Tokio Hello World出现“由于目标机器主动拒绝连接而无法建立连接”的恐慌?
这是示例hello world程序<a href="https://tokio.rs/docs/getting-started/hello-world/" rel="nofollow noreferrer">from the Tokio docume -
在删除Rust Future时紧急运行异步代码
我有一个使用<code>#[tokio::main]</code>的应用程序,该应用程序在AWS的一项任务中创建了多个资源。我已经 -
如何将Future转换为Stream?
我正在尝试使用<code>async_std</code>从网络接收UDP数据报。 有一个实现<a href="https://docs.rs/async-std/1.4.0 -
如何使用actix-web HttpResponse从Tokio TcpStream发送数据
我有一个<a href="https://docs.rs/tokio/0.2.11/tokio/net/struct.TcpStream.html" rel="nofollow noreferrer">TcpStream</a>,我需要从 -
tokio :: io :: copy获取进度回调/更新
<code>tokio::io::copy</code>不提供进度更新回调。当<code>copy</code>需要花费大量时间完成时,最好报告复制操 -
从函数返回未来值
我最近开始学习Rust,但不确定如何从应该返回结果的函数中返回将来的值。当我尝试仅返回响应变量并 -
无法将自签名证书与tokio-rustls一起使用
我正在尝试使<a href="https://github.com/quininer/tokio-rustls/tree/master/examples" rel="nofollow noreferrer">https://github.com/qu