他のものがいくつかの値を出している間に観測可能なものを1つだけ放出する

Question

私は特定のリモートマシンを監視する監視ツールのようなものを書いています。 マシンが稼動しているかどうか、IISがそこで実行されているかどうか、さらにいくつかのパラメータを取得します。
マシンのアップ/ダウン状態を3分ごとに監視できます。 IISの状態は〜1分ごとに監視できます。
これらのパラメータの一部が変更された場合、変更がログに記録されます（DistinctUntilChanged）。同じであれば何もしません。

私はマシンの状態とIISステータスのための1つの観測可能性を作成しました。 マシンがダウンしている場合は、他のリモートパラメータを監視する必要はありません（GetIisStateに電話する必要はありません）。
SkipUntilとTakeUntilを使用しようとしました - マシンがダウンしている間にポーズIisObservableをソートしようとしました。 しかし、私はそれが欲しいとはうまくいきません。ここで

は、私のマシンの状態が観測可能である：

machineStateObservable = Observable.Interval(TimeSpan.FromSeconds(180)) 
    .StartWith(-1) 
    .Select(async it => new {Order = it, State = await GetMachineStateAsync(machine)}) 
    .Switch() 
    .Do(it => 
    { 
     if (it.Order == -1) // write initial state 1st time 
     { 
      var state = it.State ? "up" : "down"; 
      var msg = $"{machine.Name}: Machine initial state: {state}"; 
      Log.Info(msg); 
     } 
    }) 
    .Select(it => it.State); 

machineStateObservable 
    .DistinctUntilChanged() 
    .Buffer(2, 1).Where(it => it.Count == 2) 
    .Subscribe(it => Log.Info($"{machine.Name}: MachineState got changed from {it[0]} to: {it[1]}") 
     , ex => Log.Error(ex, "Unhandled exception!")); 

にはどうすればmachineStateObservableは、マシンがダウンしていることを示している間、それが通知を発しないであろう（その結果GetIisStateを呼び出すことはありません）というIisObservableを定義する必要がありますか？

更新：
ここでは、私が@Enigmativityの助けを借りに来たソリューションです：

IisStateObservable = MachineStateObservable 
       .Select(state => state 
        ? Observable.Interval(TimeSpan.FromSeconds(2)).StartWith(0) 
           .SelectMany(it => Readings.GetServiceStateAsync()) 
        : Observable.Never<string>()) 
       .Switch() 
       .Publish(); 

Answer 1

ここでは別の、観察がtrueとしない場合は、それを生成したときにのみ放出することに観察を作成するための基本的なパターンですfalseを生成します。

void Main() 
{ 
    var states = new Subject<bool>(); 

    IObservable<int> query = 
     states 
      .Select(state => state 
       ? Observable.FromAsync(() => GetStatusAsync()) 
       : Observable.Never<int>()) 
      .Switch(); 
} 

public async Task<int> GetStatusAsync() 
{ 
    return await Task.Factory.StartNew(() => 42); 
} 

---

ここで私はそれが定期的に呼び出されることをお勧めしたいコードです。

void Main() 
{ 
    var states = new Subject<bool>(); 

    IObservable<int> query = 
    (
     from n in Observable.Interval(TimeSpan.FromMinutes(1.0)) 
     from ms in Observable.FromAsync(() => GetMachineStateAsync()) 
     select ms 
      ? Observable.FromAsync(() => GetStatusAsync()) 
      : Observable.Never<int>() 
    ).Switch(); 
} 

public async Task<int> GetStatusAsync() 
{ 
    return await Task.Factory.StartNew(() => 42); 
} 

public async Task<bool> GetMachineStateAsync() 
{ 
    return await Task.Factory.StartNew(() => true); 
} 

---

あるいは、ご提案の回答に基づいて。

void Main() 
{ 
    var states = new Subject<bool>(); 

    IObservable<int> query = 
     states 
      .Select(state => state 
       ? Observable 
        .Interval(TimeSpan.FromSeconds(2.0)) 
        .StartWith(-1L) 
        .SelectMany(n => 
         Observable.FromAsync(() => GetStatusAsync())) 
       : Observable.Never<int>()) 
      .Switch(); 
} 

public async Task<int> GetStatusAsync() 
{ 
    return await Task.Factory.StartNew(() => 42); 
}