This is a prep commit to break dependencies. The sub_store module is a thin layer on top of our map of stream_id -> sub.