Tagakov

fun <T> magic(jobs: Observable<Completable>, hot: Observable<T>): Observable<T> {
  return Observable.switchOnNext(jobs.map { it.andThen(hot) }.startWith(hot))
}