pub(crate) async fn handle_events<T: FakeClockObserver>(
    mock_clock: Arc<Mutex<FakeClock<T>>>,
    rs: FakeClockRequestStream
) -> Result<(), Error>