Forked aggregator (async)
[flow/Forked aggregator (async)]
Aggregates data received via data
into two output arrays, depending on whether a corresponding arbitrary input is received via true
or false
.
Releases both output arrays on receiving a signal on release
.
The input release
is independent from data
, true
, and false
.
Example:
"foo"@0 is received via
data
"bar"@1 is received via
data
"baz"@2 is received via
data
null@0 is received via
false
null@1 is received via
true
null@2 is received via
false
null@3 is received via
release
["foo", "baz"]@3 is sent via
falses
, and ["bar"]@3 is sent viatrues
Input ports
release:
any
Receives signal to release aggregated inputs. Independent of
data
.data:
any
Receives the data to be forwarded to either output.
true:
any
Receives signal that corresponding
data
should be aggregated intotrues
.false:
any
Receives signal that corresponding
data
should be aggregated intofalses
.
Output ports
trues:
any[]
Sends the aggregated data, that was accompanied by signals via
true
.falses:
any[]
Sends the aggregated data, that was accompanied by signals via
false
.
Last updated