Returns a cold flow that obtains the actual flow from provider at collection time.
provider runs once per collection, so each collector can observe a different flow.