IObservable#buffer, #join, #onceEvery, #withinTimeframe