Added stream consumers.#7

s3rius wants to merge 2 commits intomastertaskiq-python/natsrpy:masterfrom

feature/streamtaskiq-python/natsrpy:feature/streamCopy head branch name to clipboard