Given two or more source Observables, emit all of the items from only the first of these Observables to emit an item.
observable := rxgo.Amb([]rxgo.Observable{
rxgo.Just(1, 2, 3)(),
rxgo.Just(4, 5, 6)(),
})Output:
1
2
3
or
4
5
6
Given two or more source Observables, emit all of the items from only the first of these Observables to emit an item.
observable := rxgo.Amb([]rxgo.Observable{
rxgo.Just(1, 2, 3)(),
rxgo.Just(4, 5, 6)(),
})Output:
1
2
3
or
4
5
6