added socket stream pubsub