I had a quick look through existing topics, and couldn’t find this specific question.
I have the following projection:
fromStreams(’$et-eventType1’, '$et-eventType2, ‘$et-eventType3’)
return “MyPartition-” + e.data.aggregateId.replace(/-/gi, “”);
.when() //my handlers
First up, my projection starts, is it true to say that events from $et-eventType1 are processed, followed by $et-eventType2, and then finally $et-eventType3 ?
Assuming that is true, is there way to do this concurrently?
I had a look at foreachStreams, but that would create a partition per stream (which is not what I want)