Amb Operator

Overview

Given two or more source Observables, emit all of the items from only the first of these Observables to emit an item.

Example

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

Output:

1
2
3

or

4
5
6

Options

• WithBufferedChannel

• WithContext

• WithObservationStrategy

• WithErrorStrategy