停止可觀察當下一個可用

Question

我有以下幾點：

IObservable<A> as_; 
Func<A, IObservable<B>> getbs; 

getbs是返回觀察到的B秒的infinte的功能。

我希望IObservable<B>在下一個A處於「可用」狀態時立即「切換」到下一個IObservable<B>。

類似於as_.SelectMany(getbs)將不起作用，因爲它會繼續從第一個A開始B s，因爲該序列永遠不會自然終止。

Answer 1

SelectMany就像是Select後跟Merge。您需要使用Select和您的功能，然後Switch。

IObservable<int> a = Observable.Generate(0, _ => true, i => i + 1, i => i, _ => TimeSpan.FromSeconds(1)); 
Func<int, IObservable<string>> selector = i => Observable.Generate(1, _ => true, j => j + 1, j => $"{i} x {j}", _ => TimeSpan.FromMilliseconds(50)); 

a.Select(selector).Switch().Subscribe(s => Console.WriteLine(s));