open

Open the projection against a bound ThreadStream and start pumping events into store. Called once per registry entry (not per consumer). The returned dispose function is invoked when the registry's ref count for this entry drops to zero or when the registry is rebound to a different thread.