A simple mecanism:

Open an https stream to a collection, each new line is a new object event with a cursor.

Your server was down? Simply subscribe to the same collection from the last cursor saved.