pub fn merge(&self, rhs: &Self) -> Self {
    let merged = Stream::new();
    let merged_self = merged.new_same();
    let merged_rhs = merged.new_same();

    self.observe(move |sig| {
      merged_self.send(sig);
    });

    rhs.observe(move |sig| {
      merged_rhs.send(sig);
    });

    merged
  }
/// Merge two streams into one.
///
/// Merging streams enables you to perform later useful compositions, such as folding the merged
/// results.
Merge two streams into one.
Merging streams enables you to perform later useful compositions, such as folding the merged
results.
Merge two streams into one . Merging streams enables you to perform later useful compositions such as folding the merged results .
pub fn merge(&self, rhs: &Self) -> Self {
    let merged = Stream::new();
    let merged_self = merged.new_same();
    let merged_rhs = merged.new_same();
    self.observe(move |sig| {
      merged_self.send(sig);
    });
    rhs.observe(move |sig| {
      merged_rhs.send(sig);
    });
    merged
  }
pub fn merge ( & self , rhs : & Self ) -> Self { let merged = Stream :: new ( ) ; let merged_self = merged . new_same ( ) ; let merged_rhs = merged . new_same ( ) ; self . observe ( move | sig | { merged_self . send ( sig ) ; } ) ; rhs . observe ( move | sig | { merged_rhs . send ( sig ) ; } ) ; merged }
Merge two streams into one.
Merge two streams into one .
&self
rhs
&Self
&self
rhs
&Self