vi

#!/usr/bin/env run-cargo-script
//! ```cargo
//! [dependencies]
//! tokio = "=0.1.7"
//! tokio-codec = "*"
//! tokio-io = "=0.1.7"
//! futures-cpupool = "*"
//! mio = "*"
//!
//! [replace]

alex-shapiro

//! An adapter for merging the output of two streams, where
//! the stream resolves as soon either stream resolves.

use futures::{Poll, Async};
use futures::stream::{Stream, Fuse};

pub struct AndSelect<S1, S2> {
    stream1: Fuse<S1>,
    stream2: Fuse<S2>,
    flag: bool,