Merge

See also

  • Official ReactiveX documentation: Merge
classmethod Observable.merge(*args)

Merges all the observable sequences into a single observable sequence. The scheduler is optional and if not specified, the immediate scheduler is used.

1 - merged = rx.Observable.merge(xs, ys, zs) 2 - merged = rx.Observable.merge([xs, ys, zs]) 3 - merged = rx.Observable.merge(scheduler, xs, ys, zs) 4 - merged = rx.Observable.merge(scheduler, [xs, ys, zs])

Returns the observable sequence that merges the elements of the observable sequences.

../../_images/merge.png
Observable.merge_all()

Merges an observable sequence of observable sequences into an observable sequence.

Returns the observable sequence that merges the elements of the inner sequences.

../../_images/merge_all.png
Observable.merge_observable()

Merges an observable sequence of observable sequences into an observable sequence.

Returns the observable sequence that merges the elements of the inner sequences.