Add a method to load changes stream via a Stream, and trigger a callback on each change parsed. Associate an sqlite-based store for that. Still work in progress, we'll have to rewrite the reduce_changes function to use the store instead of dict() with all in memory.