fix(stream): use cursors and _time ordering

fix(stream): use cursors and _time ordering #231