rxjourney_part1_original_1.swift

let originalObservable = getObservable()

let defaultValueIfIdle = Observable<Int>.interval(5, scheduler: SerialDispatchQueueScheduler(qos: .background))
    .mapTo("defaultValue")

let observableWithDefaultValue = originalObservable
    .flatMapLatest { item in
        let currentItem = Observable.just(item)
        return Observable.of(currentItem, defaultValueIfIdle).concat()
    }
//