タスク関数から観測可能な無限IObservableであり、観測可能に切り替えます

Question

私には2つのものがあります：Task<TResult> queryとIObservable<bool> toggleを返す関数です。私が作成したいのはIObservable<TResult>です。toggleがtrueになると、毎回queryが呼び出され、結果が返される無限ループが開始されます。次に、トグルがfalseになると、無限ループが停止するはずです。

タスクから無限ループを作成する方法を読んだが、toggleをオンとオフにする方法を理解できない。また、無限ループ内でqueryを実行することはできず、フィルタリングするだけです。 toggleがfalseの場合、クエリを呼び出すべきではありません。また、toggleが偽になった場合には大丈夫です。queryがすでに開始されている場合、結果として得られる観測可能物は返されません。 toggleがfalseの場合はqueryをキャンセルすることをお勧めしますが、必須ではありません。

私は自動的にテスト可能にしたいと思います。

私は正確に何をしたいんだと思う

Answer 1

：

IObservable<TResult> query = 
    toggle 
     .Select(b => b 
      ? Observable 
       .Defer(() => Observable.FromAsync(() => SomeFunction())) 
       .Repeat() 
      : Observable 
       .Never<TResult>()) 
     .Switch();