Я пытаюсь понять, как обрабатывать новые проекции с учетом зависимостей от существующих событий.
Например, создается проекция с именем Итого заказа , и ей необходимо прослушать событие с именем OrderCaptured , чтобы построить прогноз общей стоимости заказа.
Если события уже существуют и новые события также записываются, как можно построить процесс для потоковой передачи всех существующих событий, а затем новых событий после сбора существующих событий в очередь / поток FIFO?