작업 함수에서 무한대 IObservable 및 관찰 가능 토글

Question

나는 두 가지가 있습니다 : Task<TResult> query 및 IObservable<bool> toggle을 반환하는 함수. 내가 만들고자하는 것은 IObservable<TResult>이고, toggle이 true이 될 때마다 매번 query을 호출하는 무한 루프를 시작하고 그 결과를 반환합니다. 그런 다음 false을 토글하면 무한 루프가 중지됩니다.

작업에서 무한 루프를 만드는 방법을 읽었지 만, toggle 켜고 끄는 방법을 알아낼 수 없습니다. 또한 무한 루프에서 query을 실행할 수 없으며 필터링 만 할 수 있습니다. toggle이 false 인 경우 쿼리를 호출하면 안됩니다. 또한 toggle이 false가되면 좋겠지 만 query이 이미 시작된 경우 결과 관찰 가능이 반환되지 않습니다. toggle이 거짓 일 때 query을 취소하는 것도 좋은 생각 일 수도 있지만 필수는 아닙니다.

그리고 자동으로 테스트 할 수 있기를 바랍니다. 내가 생각

Answer 1

당신이 원하는 것을 정확하게 수행합니다

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