Ask a question to get started
Enter to send•Shift+Enter new line
public Unit aggregator(Function<List<Any>, Any> aggregator)
aggregator
Function<List<Any?>, Any?>
Aggregator for streaming results.
Aggregator for streaming results. Reduces collected chunks into a single output that is then passed through [processOutputs].
