종속 관찰 가능 연결하기

Question

두 번째 API가 첫 번째 매개 변수에 의해 반환 된 값을 필요로하는 종속 API 호출을 만들어야합니다. (ID 포함) Report 모델을 업데이트 성공적인 호출이 돌아 오면, 그 후 나는 report.ID이 필요한 경우, 보고서 단계를 만들 API를 호출 할 필요가 어디 마음에 오는 첫번째 것은 flatMap

ApiManager.shared 
    .createReport(report: report) 
    .flatMap { (report) -> Observable<Report> in 
     return ApiManager.shared.createReportStep(reportID: report.ID) 
    } 

createReport 반환 Observable<Report>을 사용하고 있습니다.

모든 코드가 잘 보이고 작동하지만 문제가 발생할 때마다 (createReport 및 createReportStep) 문제가 발생합니다. onNext 블록에 코드를 삽입했지만 두 단계가 모두 완료된 후에는 한 번만 호출됩니다.

두 단계 후에 onNext 신호를 수신하는 방법이 있습니까? createReportStep에 전달할 다시 내가로부터 report.ID 업데이트합니까 어디 내가 원하는처럼 두 개의 신호를 emmit 것

ApiManager.shared 
     .createReport(report: report) 
     .concat(ApiManager.shared.createReportStep(reportID: report.ID)) 

:하지만, 나는 이런 식으로 뭔가를 사용할 수 있을까?

Answer 1

당신은 시간 구성 요소를 마음 만 모두 report에 액세스 어떤 createReportStep(reportID:)에 의해 반환이 필요하지 않은 경우, 당신은 flatMap의 블록에

ApiManager.shared 
    .createReport(report: report) 
    .flatMap { (report) -> Observable<Report> in 
     return ApiManager.shared.createReportStep(reportID: report.ID) 
      .map { (report, $0) } 
    } 

결과를 튜플을 만드는 갈 수있다 observable은 두 결과를 튜플에 포함합니다.

---

시간 구성 요소가 중요한 경우

, 당신은 여기에 다음과 같은

let report = ApiManager.shared 
    .createReport(report: report) 
    .share() 

let reportStep = report.map { $0.ID }.flatMap(ApiManager.shared.createReportStep) 

Observable.concat([report, reportStep]) 

을 할 수있는, 중요한 비트는 share 전화입니다. createReport이 한 번만 작업을 수행 할 수 있도록 보장하지만 요청한대로 다음 두 개의 이벤트가 발생합니다.