Problem I’m working on a WPF app which uses ReactiveUI and Rx, there’s part of the workflow that watches two […]
Tag: system.reactive
Create an IObservable from a method
Problem I have such a method that performs a long query search against some data. Task<List<SearchResult>> Search(string query){ … } […]
Async selector in LINQ
Problem LINQ Select usually works like this: IEnumerable<Task<int>> res = new[] {1,2,3}.Select(async i => i); I would like to have […]
Is this a good example of Reactive Extensions? How can I make this better?
Problem using System; using System.Collections.Generic; using System.Linq; using System.Reactive.Linq; using System.Threading; using Newtonsoft.Json; using Newtonsoft.Json.Linq; using RestSharp; namespace ReactiveExtensions { […]
RX fluent subscribing to observables
Problem I have three observables: var itemsManipulationStarted = Observable.FromEvent<ManipulationStartedEventArgs>(Items, “ManipulationStarted”); var pageManipulationDelta = Observable.FromEvent<ManipulationDeltaEventArgs>(this, “ManipulationDelta”); var pageManipulationCompleted = Observable.FromEvent<ManipulationCompletedEventArgs>(this, “ManipulationCompleted”); […]
Is this an ugly/incorrect usage of subscriptions?
Problem Little backstory: I’m trying to write code that will read messages from INetworkConnection that the INetworkConnection publishes and then […]
Observable timer sequence
Problem This question over on SO about how to call a function “later” using Rx led me to post the […]
pull things from lazy source till timeout is reached
Problem I need to pull things from lazy source till timeout is reached in this fashion: var results = lazySource.SelectMany(item […]
pull things from lazy source till timeout is reached
Problem I need to pull things from lazy source till timeout is reached in this fashion: var results = lazySource.SelectMany(item […]
Create an IObservable from a method
Problem I have such a method that performs a long query search against some data. Task<List<SearchResult>> Search(string query){ … } […]
- 1
- 2