collect

open suspend override fun collect(collector: FlowCollector<T>)

Requests MapReduceFlow to start streaming data according to the specified map-reduce function with the given options.

If the aggregation produces results inline, then finds all documents in the affected namespace and emits them. You may want to use toCollection instead.
Otherwise, emits no values.