2

キューのように使用する BlockCollection の Observable があります

IObservable<ProcessHoldTransactionData> GetObservable()
{     
    _queue.GetConsumingEnumerable().ToObservable(TaskPoolScheduler.Default);
}

そして彼を購読してください：

void StartSubscription()
{
    _subscription = =  GetObservable().Subscribe(
                data => OnNextSubscribe(data),
                ex => _logger.Error("Error"),
                () => _logger.Warn("Complete"));
}

今、私は別のオブザーバブルを持っています:

var timer = Observable.Interval(TimeSpan.FromSeconds(60));
_subscriptionTimer = timer.Subscribe(tick =>
{
    OnTimerNextSubscribe();
});

OnTimerNextSubscribeが_subscriptionの購読を停止し、OnTimerNextSubscribe が終了したときにそれを更新し始めたときに希望します。

それに最適なパラクティスは何ですか？_subscriptionを破棄してStartSubscription()を呼び出す
必要がありますか

4

1 に答える 1