rebound.swift

extension Observable {
    func rebound(after interval: RxTimeInterval, map: @escaping (Element) -> Element = { return $0 }) -> Observable<Element> {
        return flatMap { element in
            return Observable.just(map(element))
                .delay(interval, scheduler: MainScheduler.instance)
                .startWith(element)
        }
    }
}