问题标签 [tokio]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
rust - 正常关闭 warp 服务器
我正在用 Rust 编写一个带有 warp 的服务。当服务收到 SIGTERM 信号时，我想让它正常关闭，并可能做一些日志记录或其他工作。
我尝试了许多示例，但没有任何效果。最有希望的似乎是这个链接：
https://github.com/seanmonstar/warp/issues/195
但我似乎无法让它发挥作用。我怀疑自从回答这个问题后事情已经发生了变化。
这是我的货物文件：
这是我的 main.rs：
在这一点上，它甚至没有编译。我收到几个看似无关的错误：
任何建议或更好的更新代码将不胜感激。
谢谢。
asynchronous - 如何使用 Tokio 正确执行批量 HTTP 请求？
我想要做的是将所有 JobHandles 保存在一个向量中，并在迭代 X 时间后我想等待它们。
我这样做是因为如果我在特定时间范围内发送太多请求，我发送请求的端点也会返回 429 错误。
到目前为止，我有这个。这很好用，但只有当我在 else 中有中断时才有效。我希望能够在没有中断的情况下批量处理 5 个请求。如果没有休息，我会收到这样的错误：
好的，我解决了移动问题。现在我有这个问题。
我应该如何继续我想做的事情？
rust - 对等方重置连接。东京，选择
我正在编写 socks5 代理服务器。该程序正在异步运行，我正在尝试使用tokio::select，但是当我想获取接收数据的大小时，程序由于此错误而终止：
发生错误的函数：
rust - 如何在并发上共享 tokio::net::TcpStream？
我需要在同一个 TcpStream 上发送和接收正常数据，同时定期发送心跳数据。在当前的实现中， Arc<Mutex> 用于我的目的，但它编译时出错。如何修复这些错误，或者是否有其他方法可以实现相同的目标？
在这里欣赏任何建议。
谢谢。