Add flush method to throttled observables