* Initial POC * Allow the queue to fill by waiting for the lag in IPC * Add docs * Add run_tests * Add reactor to tests