I need to use reduce operator on an observable to ...

# rx

[dave08]

I need to use reduce operator on an observable to make a map out of all the observable's results, but if I do reduce(mutableMapOf(), { map, row -> map.put(row.name, row) } and my observable needs to return a Map<String, RowType>, it doesn't have an reduce overloads that match... How could I do this cleanly (I'm also using rxkotlin.. but it seems like it doesn't have anything for this particular problem...)