rxjourney_part1_original_2.swift

let originalObservable = getObservable().share()

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

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

let finalOutput = Observable.merge(defaultValueIfIdle.takeUntil(originalObservable), observableWithDefaultValue)

//