rxjourney_part1_new_1.swift

1. let originalObservable = getObservable().share()

2. let defaultValueAfterFiveSeconds = originalObservable.flatMapLatest { item in
		return Observable<Int>.interval(5, scheduler: SerialDispatchQueueScheduler(qos: .background))
			.mapTo(“defaultValue”)
	}
3. let initialDefaultValue = defaultValueIfIdle.takeUntil(originalObservable)
   let finalOutput = Observable.merge(originalObservable, defaultValueAfterFiveSeconds, initialDefaultValue)

//