Improved logic of pub/sub tests
added streaming response