rxjava отличается тайм-аутом и состоянием

Question

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

private final Handler handler = new Handler()

@Override
public void onEvent(EventType type) {
    handler.removeCallbacksAndMessages(null);
    if(type == EventType.CONDITION_1){
        startTask();
    } else {
        handler.postDelayed(() -> startTask(), 1000);
    }
}