Czar
08/20/2020, 10:03 AMconsumeEach
assumes that the actor is temporary and will be closed after each message is processed, while in my case, the actor should probably persist, even if at the moment there are no new events.
Another problem with actor is, that by making it unbounded I can run into OOM if there is a spike in events count, this is where I need backpressure and cannot just read events from the repository with constant rate.Tijl
08/20/2020, 10:20 AMFlow
Czar
08/20/2020, 10:36 AMTijl
08/20/2020, 11:55 AMdave08
08/21/2020, 2:26 AMCzar
09/04/2020, 11:06 AM