Like IQueryable, you cannot evaluate an expression twice in a chain of operations (since you can extract the main expression), IQbservable has the same advantages. You can get the full observable expression so that you can create custom Rx implementations (how you can do Linq-to-SQL, Linq-to-XML, Linq-to-Twitter, etc.).
Some ideas for implementing IQbservable? What about:
- Node.js style single-threaded IQbservable, no locks, only runloop
- Rx-to-ServiceBus, which implements blocking operations and schedulers as separate machines and awaiting results instead of using simple locks and task elements
source
share