We should initialize this from the `streams` key in the initial snapshot (`InitialSnapshot`), and keep it updated in response to `stream` events.