这是一个示例程序:
extern crate futures;
extern crate tokio_core;
use futures::{Async, Future, Stream};
use tokio_core::reactor::Core;
use tokio_core::net::TcpListener;
fn main() {
let mut core = Core::new().unwrap();
futures::sync::oneshot::spawn(
TcpListener::bind(&"127.0.0.1:5000".parse().unwrap(), &core.handle())
.unwrap()
.incoming()
.for_each(|_| {
println!("connection received");
Ok(())
}),
&core,
);
let ft = futures::future::poll_fn::<(), (), _>(|| {
std::thread::sleep_ms(50);
Ok(Async::NotReady)
});
core.run(ft);
}
如您所见,我调用oneshot::spawn
然后立即删除它的返回值,理论上应该取消其中包含的未来。但是,当我运行这个程序然后连接到 时127.0.0.1:5000
,它仍然会打印“已收到连接”。为什么这样做?我希望它不会打印任何东西并TcpListener
从端口中删除 , 解除绑定。