Pin不稳定的Rust中有一个新类型,RFC已经合并.据说传递引用时它被称为游戏改变者,但我不确定如何以及何时应该使用它.
任何人都可以用外行的话来解释它吗?
我刚开始在Rust尝试期货/ tokio.我可以用期货或只用流来做基本的事情.我想知道如何在未来和流之间进行选择.
如何将tokio文档中的玩具问题扩展到用于tokio_timer::Timer执行定时HTTPS请求?
extern crate futures;
extern crate native_tls;
extern crate tokio_core;
extern crate tokio_io;
extern crate tokio_tls;
use std::io;
use std::net::ToSocketAddrs;
use futures::Future;
use native_tls::TlsConnector;
use tokio_core::net::TcpStream;
use tokio_core::reactor::Core;
use tokio_tls::TlsConnectorExt;
fn main() {
let mut core = Core::new().unwrap();
let handle = core.handle();
let addr = "www.rust-lang.org:443".to_socket_addrs().unwrap().next().unwrap();
let cx = TlsConnector::builder().unwrap().build().unwrap();
let socket = TcpStream::connect(&addr, &handle);
let tls_handshake = socket.and_then(|socket| {
let tls = cx.connect_async("www.rust-lang.org", socket);
tls.map_err(|e| {
io::Error::new(io::ErrorKind::Other, e)
})
});
let request = tls_handshake.and_then(|socket| { …Run Code Online (Sandbox Code Playgroud) 我正在尝试使用async_std从网络接收 UDP 数据报。
有一个UdpSocket实现async recv_from,这个方法返回一个未来,但我需要一个async_std::stream::Stream提供UDP数据报流的,因为它是一个更好的抽象。
我发现tokio::net::UdpFramed这正是我需要的,但它在当前版本的 tokio 中不可用。
一般来说,问题是如何将Futures 从给定的异步函数转换为Stream?