Add user stream support and some utilities for operating on message dicts.