Split NSQ test into separate functions for writing to and reading from topics
Split NSQ test into separate functions for writing to and reading from topics

pfig/streamtools,jacqui/streamtools,nytlabs/streamtools,nytlabs/streamtools,pfig/streamtools,pfig/streamtools,wxdublin/streamtools,nytlabs/streamtools,wxdublin/streamtools,deepglint/streamtools,pfig/streamtools,deepglint/streamtools,nytlabs/streamtools,deepglint/streamtools,jacqui/streamtools,deepglint/streamtools,jacqui/streamtools,wxdublin/streamtools,wxdublin/streamtools,jacqui/streamtools