Aggregator (async)
[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
Input ports
data:
any
Receives data items to be aggregated.
release:
any
Receives signal to release aggregated inputs. Independent of
data
.
Output ports
aggregated:
any[]
Sends the aggregated data.
Last updated