Add Observable.take(timespan) + drop(timespan)