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