Sequential observables

Sequential observables

ObstetricBabyManager
    .getAll()
    .doOnNext { baby in
        baby.Name = "John Smith"
    }
    .observeOn(ConcurrentDispatchQueueScheduler.init(queue: AsyncTaskUtil.backgroundThread))
    .subscribeOn(MainScheduler.instance)
    .flatMap { baby in
        return ObstetricBabyManager.persist(baby)
    }
    .subscribe (
        onNext:
        {
            print ($0.Name)
        },
        onError: { error in
            print (error)
        }
    )
    .addDisposableTo(garbageBag)