小编twi*_*sel的帖子

我正在尝试将 future 附加到BufferUnordered. 目前，我将它们直接推入底层流，Fuse流BufferUnordered是空的，因此推入它没有效果，并且下面的循环不会收到第三个响应。next更改(1)的定义stream.buffer_unordered(1)似乎可以使其工作，因为底层流不是空的/已完成的。

extern crate url;
extern crate futures;
extern crate tokio_core;
extern crate reqwest;

use url::Url;
use futures::*;
use tokio_core::reactor::Core;
use reqwest::unstable::async::{Client, Response, Decoder};

fn main() {
    let mut core = Core::new().unwrap();
    let client = Client::new(&core.handle()).unwrap();
    let hyper = client.get("https://hyper.rs").unwrap().send();
    let google = client.get("https://google.com").unwrap().send();
    let stream = stream::futures_unordered(vec![future::ok(hyper), future::ok(google)]);

    let mut next = stream.buffer_unordered(5).into_future(); // (1)
    loop {
        match core.run(next) {

            Ok((None, _something)) => {
                println!("finished");
                break;
            }, …