C#-仓库中连续(异步)对象流的可观察(Rx)
作者：互联网
我有一个类型为Item的存储库.我的目标是让该存储库使用Observable提供Item的Observable或基本上是“流”.
我是RX的入门者,但我认为我对基础知识有很好的了解.我的问题是找到一种使Observable保持活动状态的方法,并在项进入时将其手动推入(可能是套接字或其他基于异步的项).基本上是可观察的热点.
我使用Subject< Item>我订阅了该文件,但缺少“常规可观察”的功能,即LINQ查询来过滤流.恐怕我正在忽略某些东西,或者已经超越了合适的方法.
对于像我这样的初学者的任何见解或方向,我们将不胜感激.
解决方法:
您可能会缺少使用System.Reactive.Linq的引用,否则请选择et.等应该出现在主题T上.
标签：system-reactive,asynchronous,repository,c 来源： https://codeday.me/bug/20191101/1986912.html