Aggregator (async)
Last updated
Last updated
[flow/Aggregator (async)]
Aggregates inputs into an array until released.
The release
signal is received and processed independently from those received via data
. (As opposed to flow/Aggregator
.)
The output reflects the order as received through data
.
Example:
"a"@0 is received via data
"b"@1 is received via data
null@2 is received via release
["a", "b"]@2 is sent via aggregated
Keywords: aggregate, collect, accumulate, burst
data: any
Receives data items to be aggregated.
release: any
Receives signal to release aggregated inputs. Independent of data
.
aggregated: any[]
Sends the aggregated data.