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

EventStoreDB
1

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.

2

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