Adds support for asynchronous polling.
Creates a simple public API.
Refactors tests to add pipeline and pubsub demo.
Beef up dat README