Merge Operator

Overview

Combine multiple Observables into one by merging their emissions.

Example

observable := rxgo.Merge([]rxgo.Observable{
	rxgo.Just(1, 2)(),
	rxgo.Just(3, 4)(),
})

Output:

1
2
3
4

Options

• WithBufferedChannel

• WithContext

• WithObservationStrategy

• WithErrorStrategy

• WithPublishStrategy