Observableにdo if演算子がありますか？

Question

私の状況は私がダイアログをオープンしようとしていて、ダイアログオブザーバブルがtrueの値を返す場合にのみswitchMapを別のオブザーバブルにしたい場合は、エラーを表示して次のアクションを停止します。

現在、私は次のようにあります

this.dilog.open(DialogComponent) 
    .afterClosed() 
    .takeUntil(this.end$) 
    .do(item => { 
     if (!item) { 
     this.error = 'Please accept the agreement to continue.' 
     this.isSubmitting = false; 
     } 
    }) 
    .filter(item => !!item) 
    .switchMap(item => anotherObservable) 

私はこのコードの可読性を向上させたいです。

Answer 1

RxJSのバージョン5.5ではなく、もっと簡単にcreate your own operatorsとしています。以下は、数ヶ月の時にコードをちらっと見たときに、うまくいけば、読みやすさを向上させる機能です。

// source: source observable 
// onError: function to execute on error 
// onSuccess: observable to switchMap to 
function showErrorOrSwitchMap(source, onError, onSuccess) { 
    return source 
     .do(item => { 
      if (!item) { 
       onError(); 
      } 
     }) 
     .filter(item => !!item) 
     .switchMap(item => onSuccess) 
} 

// USAGE 
showErrorOrSwitchMap(
    this.dilog.open(DialogComponent) 
     .afterClosed() 
     .takeUntil(this.end$), 
    function() { 
     this.error = 'Please accept the agreement to continue.' 
     this.isSubmitting = false; 
    }, 
    anotherObservable 
); // You can continue the observable chain here if you want 

これはちょうどあなたのコードでは、関数内に移動。元のコードは変更されませんが、関数が使用されている場所では（うまくいけば）読みやすくなります。