Stream.runForEach exiting early when using PubSub - Effect Community