How do you "zip" events from 2 streams to create new event

I am trying to get events from two event stream to produce new stream, but I am lost as far as how to get that done using ES projections.

Both event types have same correlation Id and are coming from β€œ$et” streams . Is there handler that delivers these events as collection grouped by correlationId? I looked in documentation, but it is very terse, without any examples :frowning:

Basically I want to takes these 2 type of events, extract data, and emit new stream.

Projections support fromStreams(["$ce-stream1", β€œ$ce-stream2”, β€œ$ce-stream3”]) instead of fromAll() if that’s what you mean.