Transform the Observable items into a Single emitting a map. It accepts:
- A function that transforms each item into its corresponding key in the map.
- A function that transforms each item into its corresponding value in the map.
observable := rxgo.Just(1, 2, 3)().
ToMapWithValueSelector(func(_ context.Context, i interface{}) (interface{}, error) {
return i.(int) * 10, nil
}, func(_ context.Context, i interface{}) (interface{}, error) {
return i, nil
})
Output:
map[10:1 20:2 30:3]