fn merge<S1>(self, other: S1) -> Box<dyn Stream<Item = Self::Item> + Unpin>
    where
        Self: Sized + 'static,
        S1: Stream<Item = Self::Item> + 'static,
    {
        Box::new((self, other).merge())
    }
/// Combines multiple streams into a single stream of all their outputs.
///
/// Items are yielded as soon as they're received, and the stream continues
/// yield until both streams have been exhausted. The output ordering
/// between streams is not guaranteed.
///
/// # Examples
///
/// ```
/// use futures::stream::StreamExt;
/// use futures_concurrency::prelude::*;
/// use futures_lite::future::block_on;
/// use futures_lite::stream;
///
/// fn main() {
///     block_on(async {
///         let a = stream::once(1u8);
///         let b = stream::once(2u8);
///         let mut s = a.merge(b);
///
///         let mut buf = vec![];
///         while let Some(n) = s.next().await {
///             buf.push(n);
///         }
///         buf.sort_unstable();
///         assert_eq!(&buf, &[1u8, 2u8]);
///     })
/// }
/// ```
Combines multiple streams into a single stream of all their outputs.
Items are yielded as soon as they're received, and the stream continues
yield until both streams have been exhausted. The output ordering
between streams is not guaranteed.
Combines multiple streams into a single stream of all their outputs . Items are yielded as soon as they ' re received and the stream continues yield until both streams have been exhausted . The output ordering between streams is not guaranteed .
fn merge<S1>(self, other: S1) -> Box<dyn Stream<Item = Self::Item> + Unpin>
    where
        Self: Sized + 'static,
        S1: Stream<Item = Self::Item> + 'static,
    {
        Box::new((self, other).merge())
    }
fn merge < S1 > ( self , other : S1 ) -> Box < dyn Stream < Item = Self :: Item > + Unpin > where Self : Sized + ' static , S1 : Stream < Item = Self :: Item > + ' static , { Box :: new ( ( self , other ) . merge ( ) ) }
Combines multiple streams into a single stream of all their outputs.
Combines multiple streams into a single stream of all their outputs .
self
other
S1
examples


fn main() {
block_on(async {
let a = stream::once(1u8);
let b = stream::once(2u8);
let mut s = a.merge(b).


fn main () { block_on ( async { let a = stream :: once ( 1u8 ) ; let b = stream :: once ( 2u8 ) ; let mut s = a . merge ( b ) .