Implement Observable.bufferWithTimeout()