我有一个 Repository类型 Item我的目标是拥有 Repository提供一个Observable或者基本上是 Item 的“流”使用 Observable。
我是 RX 的初学者，但我认为我已经很好地掌握了基础知识。我的问题是找到一种方法来保留 Observable活着并手动推送 Item当它们进来时(可能是套接字或任何其他基于异步的)。基本上是一个热 Observable。
我使用 Subject<Item> 让它工作我订阅了它，但我缺少“常规 Observable”的功能，即用于过滤流的 LINQ 查询。恐怕我忽略了某些东西或看过去了一种合适的方法。
非常感谢像我这样的初学者的任何见解或方向。
最佳答案
您可能缺少一个 using System.Reactive.Linq引用，否则选择等。阿尔。应该出现在 Subject<T> 上.
关于c# - 可观察 (Rx) 用于存储库中的连续(异步)对象流，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/8662613/