Наблюдаемые с деревом решений

Question

мне нужна функция, которая инкапсулирует сложный IAP покупки дерева в простую функцию attemptPurchase, которая возвращает булеву наблюдаемую (истину -> успех, ложная -> отмененная, ошибки -> любой ошибки)

Но я в тупике о том, как я могу создать эту функцию, в основном вызывают начало асинхронного решения.

Дерево решений и код ниже => справка очень ценится!

// fails -> missing return function 
// but i cannot return the credit check, since the execution is different depending on the result 

func attemptPurchase(amount: Int) -> Observable<Bool>{ 

    let creditCheck = creditCheck(amount) 

    creditCheck.filter{$0}.subscribeNext{ _ in 
    return Observable.just(true) 
    } 

    creditCheck.filter{$0}.subscribeNext{ _ in 
    return confirmIAP().processIAP() 
    } 
} 

func creditCheck(amount: Int) -> Observable<Bool>{ 
    return API.creditCheck.map{$0 > amount} 
} 

func confirmIAP() -> Observable<Bool> { 
    // UI for confirming IAP 
} 

func processIAP() -> Observable<Bool> { 
    // UI for uploading IAP on my server 
} 

Answer 1

Это, как вы могли бы сделать это:

func attemptPurchase(amount: Int) -> Observable<Bool> { 
    return creditCheck(amount) 
     .flatMapLatest { (enoughCredit: Bool) -> Observable<Bool> in 
      if enoughCredit { 
       return Observable.just(true) 
      } else { 
       return confirmIAP() 
        .flatMapLatest { (isConfirmed: Bool) -> Observable<Bool> in 
         if isConfirmed { 
          return processIAP() 
         } else { 
          return Observable.just(false) 
         } 
        } 
      } 
     } 
} 

Answer 2

От ответа iankeen «s в ослабленном группе RxSwift:

func attemptPurchase(amount: Int) -> Observable<Bool>{ 
    return creditCheck(amount) 
     .flatMap { enough in 
      return (enough ? .just(true) : confirmIAP()) 
     } 
     .flatMap { ready in 
      guard ready else { /* failure */ } 
      return processIAP() 
     } 
}