Transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable.
observable := rxgo.Just(1, 2, 3)().FlatMap(func(i rxgo.Item) rxgo.Observable {
return rxgo.Just(i.V.(int) * 10, i.V.(int) * 100)()
})Output:
10
100
20
200
30
300