反応的なデザイン：スローとパブリッシュのエラー

Question

次のコード例は、（Rx）Swiftの臭いがありますが、反応性機能とスロー機能を備えたすべての言語に共通の質問です。

観測可能なシーケンスを返す関数を考えてみましょう。ただし、シーケンスを作成する前にいくつかのサニティチェックを行います。チェック失敗は、シーケンスが値を生成できないことを意味します。

状態妥当性チェックに失敗した場合には

func yieldFoos() -> Observable<Foo> { 
    guard isValid(internalFoo) else { 
    // throw or return one shot observable? 
    } 
    return createValidObservable(from: internalFoo) 
} 

、関数throwや、これまで単にエラーが発生します観察可能なワンショットを、返す必要がありますか？

スローイングは論理的にきれいになります（これは障害が発生するのを防ぐためのものです）が、実行コードが違って実行ブロックが異なるため、異なる実行スコープの複数のエラー処理ポイントが発生します。

観察可能なワンショットは、より短くてきれいな呼び出しコードになりますが、何らかの形で間違っていると感じます。観察可能性は、簡潔さのために、非順次エラー状態のための搬送波であることが強制される。

次のような意見がありますか？見過ごされていた別の優雅なソリューションですか？あなたはそれを呼び出すとき、

func yieldFoos() -> Observable<Foo> { 
    Observable.create { observer in 

     guard isValid(internalFoo) else { 
      observer.onError(yourError) 
     } 

     let subscription = 
      createValidObservable(from: internalFoo) 
       .subscribe(onNext: { foo in 
        observer.onNext(foo) 
        observer.onCompleted() 
       }) 
     return Disposables.create { 
      // your dispose 
      subscription.dispose() 
     } 
    } 

} 

そして：

Answer 1

私はそれがエラーが発生することは観察可能なため間違っていることを、あなたの気持ちについてのだろうか。それは仕事の一部です。

考えてみるとcreateValidObservable(from:)関数は有効なinternalFooを渡してもエラーを出す可能性がありますので、yieldFoos()というコードは、とにかく出力エラーを処理できるように準備する必要があります。すべてのエラー処理コードをまとめてロールバックすることもできます。私はさらに進んで、作成関数がエラーを出してyieldFoos関数を削除することによって、無効なfoos自体を処理できるようにします。あなたがしたい場合は、投げたり前提条件によってエラーを処理する必要が

さて、yieldFoos()はその後、観測可能ではなくをDriverを戻します（ドライバがエラーを出さないため。）

func yieldFoos() -> Observable<Foo> { 
    guard isValid(internalFoo) else { 
     return Observable.error(myError) 
    } 
    return createValidObservable(from: internalFoo) 
} 

私はObservableを持ってすぐにエラーを返すのは間違っているというあなたの気持ちを乗り越える必要があると思います。それはObservableが行うための完全に有効なものであり、Observableを使用するすべてのコードが処理する準備が必要です。

Answer 2

あなたの機能は次のようなものでなければなりません

yieldFoos() 
    .subscribe(
    onNext: { foo in 
     // your code with foo 
    }, 
    onError: { error in 
     // manage errors 
    }) 
    .addDisposableTo(disposeBag)