Stream.runForEach exiting early when using PubSub
https://effect.website/play#8511894b361e
I'm confused why
I'm confused why
runForEach exits after processing the first message, I can work around it by pulling values in a while loop but I'd expect this setup to work. Am I doing something wrong with the scopes of each effect?