observable_merge

Combine many observables of the same output type into one by subscribing to all of them at once.

See Also

• ConcatObservable - Combine many observables of the same output type by subscribing to them sequentially in order.

Example

cargo run -p rx_core --example observable_merge_example

let observable_1 = (1..=3).into_observable().skip(2);
let observable_2 = (4..=6).into_observable().take(1);
let observable_3 = (95..=98).into_observable();

let _subscription = merge((observable_1, observable_2, observable_3), usize::MAX)
    .subscribe(PrintObserver::<i32>::new("merge_observable"));

Output:

merge_observable - next: 3
merge_observable - next: 4
merge_observable - next: 95
merge_observable - next: 96
merge_observable - next: 97
merge_observable - next: 98
merge_observable - completed
merge_observable - unsubscribed