設定時間の経過後、どのようにオブザーバブルを処分できますか？

Question

私は観測者に、2秒ごとに固定されたレートでデータを送信しているという観測可能性を持っています。私は、2分後にデータを送信しているオブザーバブルが、完了したことを被験者に伝えた後、それ自体を廃棄する方法が必要です。私は2秒間隔のデータを発信するための2つのタイマーと、合計2分の時間のためのもう1つのタイマーを使用していますので、OnCompleteを送信できます。私はタイマーを使って2分が終わった後も自分自身を処分する方法があるのだろうかと思っていましたか？

Observable.Create<>(
    observer => 
    { 
     var timer = new Timer(); 
     timer.Elapsed += (s, e) => observer.OnNext(*send some string*); 
     timer.start(); 
     return Disposable.Empty; 
    } 
) 

Answer 1

それは本当にかなり単純です：

私のコードは次のようになります。ちょうどこれを行う：

Observable 
    .Interval(TimeSpan.FromSeconds(2.0)) 
    .TakeUntil(Observable.Timer(TimeSpan.FromMinutes(2.0))) 
    .Subscribe(x => 
    { 
    }); 

これは自動的に2分後に観察可能性を終了し、あなたのためにすべてを解除します。