c# - 接收 : Create a subsequent observable from an observable with a different type (Chaining observers)

Question

我们有一种情况，对服务的方法调用返回一个 IObservable<T1>但我们的客户期望 IObservable<T2> .将 T1 转换为 T2 很简单。

Rx 中有什么允许这样做的吗？ (即链接观察者)

我知道我可以手动创建一个辅助观察者，然后监听原始观察者的变化并使用新类型转发它们，但我想知道是否有更简洁的方法来做到这一点？

非常感谢，

Answer 1

您可以投出您的 IObservable<T1>至 IObservable<T2>使用 Select

IObservable<T2> stream = service.MethodCall().Select( TrivialConversion );

private T2 TrivialConversion( T1 param )
{
    return new T2( param );
}