updated to subscribe to streams