连接被对等方重置。东京,选择
我正在写socks5代理服务器。该程序正在异步运行,我尝试使用 tokio::select,但是当我想获取接收到的数据的大小时,程序由于此错误而终止: thread 't…
使用 tokio 以编程方式创建和侦听多个信号和滴答间隔
我正在尝试以编程方式监听多个信号和滴答间隔。 为了澄清事情,这是我目前拥有的代码: use std::time::Duration; use tokio::signal::unix::SignalKi…
如何在单个任务中同时读取来自多个 Tokio 频道的消息?
我想读取和处理来自两个通道的消息并构造另一条消息并通过另一个通道发送该消息。 来自两个通道的消息以不同的频率接收(根据 sleep)。 示例:收到“…
错误:无法为 `syn` 选择版本
error: failed to select a version for `syn`. \ ... required by package `serde_derive v1.0.125`\ ... which satisfies dependency `serde_derive…
如何使用 Tokio 和 Surf 正确执行批量 HTTP 请求?
我想做的是将所有 JobHandle 保存在一个向量中,并在迭代 X 时间后我想等待它们全部。 我这样做是因为如果我在特定时间范围内发送太多请求,我发送请…
是否有一种 FuturesOrdered 替代方案可以一一产生结果?
在 Rust 中,我有一堆想要并行执行的异步函数。处理这些函数的结果的顺序很重要。我还想在这些函数可用时检索它们的结果。 让我不好解释一下。 以下是…
Rust tokio:在生成的线程中等待异步函数
尝试在新的 tokio 线程内调用异步函数会导致某些函数出错。 在这个最小的示例中,使用了 crates tokio 和 iota-streams。 send_announce() 方法是异步…
- 共 1 页
- 1