Effect CommunityEC
Effect Community8mo ago
4 replies
Brendonovich

Stream.runForEach exiting early when using PubSub

https://effect.website/play#8511894b361e
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?
Was this page helpful?