consumer
========

.. automodule:: unistream.consumer
    :members: