fix(watch/stream): queue events in history first