Как вы проводите модульное тестирование операторов Rx, которые используют таймеры?

Существует ряд операторов, основанных на таймере, и я, хотя у меня нет конкретного примера, считаю обычным создание новых операторов, использующих таймеры. Итак, как бы вы написали тест, который запускается синхронно для этих операторов?

В качестве примера, как я могу выполнить модульное тестирование такого оператора, как BufferWithTime?