c# - 将 IObservable<(long,float)> 拆分为 IObservable 和 IObservable 两个可观察对象

Question

我有一个 IObservable<(long, float)> 类型的流(热可观察)并想将其分成 IObservable<long> 的两个可观察对象和 IObservable<float>

我天真地尝试了以下但我只得到 flowStream人口稠密。

IObservable<long pressure, float flow> sourceHotObservable = GetStream(); 

var pressureStream = sourceHotObservable.Select(i => i.pressure);
var flowStream = sourceHotObservable.Select(i => i.flow);

Answer 1

您当前的代码似乎工作正常。

如果我尝试这样做:

var sourceHotObservable = Observable.Return((pressure: 1L, flow: 3.0f)).Publish();

var pressureStream = sourceHotObservable.Select(i => i.pressure);
var flowStream = sourceHotObservable.Select(i => i.flow);

pressureStream.Subscribe(Console.WriteLine);
flowStream.Subscribe(Console.WriteLine);

sourceHotObservable.Connect();

我明白了:

13