Demonstrating creating a stream, publishing, and subscribing flow - View it on GitHub