system.reactive
Transform IObservable of strings into IObservable of XDocuments
I have an IObservable<string> that contains (fragments of) XML documents. I\'d like to transform one into the other. So for example, suppose I have the following fragments that are pushed from m[详细]
2023-03-10 00:45 分类:问答ReactiveExtensions BufferWithPredicate
Rx has methods for BufferWithTime, BufferWithCount and BufferWithTimeOrCount, I want to write a BufferWithPredicate method, which would look like so:[详细]
2023-03-09 04:04 分类:问答How to cancel asynchronous method called using Rx
I want to know how to cancel\\stop asynchronous method called using reactive extensions using the TakeUntil.[详细]
2023-03-09 02:57 分类:问答Reactive Extensions wait for method to finish
We are starting to refactor our silverlight application using some reactive extensions. I have an Initialize method that does some work. I have a call to a method within the Initialize method that mus[详细]
2023-03-08 12:59 分类:问答ObserveOn with Scheduler.NewThread does not observe so, if observer's OnNext is blocked and continued
Can some one please help explain why when I \"block and continue\" observer\'s onNext sequence subscribed to a buffer with time observable sequence, that Scheduler.NewThread does not apply anymore?[详细]
2023-03-07 22:28 分类:问答Rx Disposing a subscription
What is the recommended way to dispose of subscriptions that are created in a loop? In the following contrived example I\'m generating subscriptions in a for loop and adding them to a List and disposi[详细]
2023-03-06 18:29 分类:问答Need help with RX:Convert System.Diagnostics.Process.OutputDataReceived to an Observable
I want to start a subprocess and watch it\'s redirected out开发者_开发问答put. That not a problem for me in C#, but I try to understand RX, so the game begins ...[详细]
2023-03-06 12:09 分类:问答Distinct between possible streams, looking for a clean solution
I\'m trying to use RxJS in some GUI scenarios. I came across an interesting case. I have a widget where one can view, edit and create entities.[详细]
2023-03-06 09:25 分类:问答Reactive framework eliminate while loop in Observable.Create
I am working with an observable byte stream, coming off of the network, and I would like to take that up one layer of abstraction.The format has two bytes that contain the length of the next message.I[详细]
2023-03-06 01:13 分类:问答Handling database connection exceptions with Linq to SQL and Rx
I am trying learn how to best use the Reactive Extensions library and have set up simple test WPF application to view a logging database table. In a ViewModel class I am 开发者_如何转开发populating an[详细]
2023-03-05 23:00 分类:问答