Collecting Current Values from an Ongoing Stream - Effect Community