I have this method where i use a Mongodb Aggregation Pipeline to gather all values for specific year/month in a list. Afterwards i'm calling collect on this publisher to map each year/month to the average value of this list and emit it.

    fun overallTrends(metricName: String) = flow {
        val mongoList = col.aggregate<OverallTrend>(
                """
[
    { $ group:
        {
             _id: {
                year: "$ metaData.reportingYear",
                month: "$ metaData.reportingMonth"
            },
            values: { $ push: "$ $metricName" }
        }
    }
]""".formatJson()
        )
        mongoList.collect { trend ->
            val yearMonth = trend.id.toYearMonth()
            emit(yearMonth to trend.averageValue)
        }
    }

I want to call a terminal operation on this flow to get a Map.
Therefore currently i have to it this way:
val overallTrendsMap = mongoMetricsService.overallTrends(mongoMetricName).toList().toMap()
I would be more performant and nicer to read if i could directly call it like this:
val overallTrendsMap = mongoMetricsService.overallTrends(mongoMetricName).toMap()

Provide associate terminal operators #1541

Description

Activity

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions

Provide `associate` terminal operators #1541