Trait rxrust::ops::merge::Merge

pub trait Merge {
    fn merge<S>(self, o: S) -> MergeOp<Self, S>
    where
        Self: Sized,
    { ... }
}

combine two Observables into one by merging their emissions

Example

let numbers = Subject::local();
// crate a even stream by filter
let even = numbers.fork().filter(|v| *v % 2 == 0);
// crate an odd stream by filter
let odd = numbers.fork().filter(|v| *v % 2 != 0);

// merge odd and even stream again
let merged = even.merge(odd);

// attach observers
merged.subscribe(|v: &i32| println!("{} ", v));

Provided methods

fn merge<S>(self, o: S) -> MergeOp<Self, S> where
    Self: Sized, 

Loading content...

Implementors

impl<O> Merge for O

Loading content...