added basic pubsub for stream store