.. automodule:: streaming.abstractstream