I have an async method, say: public async Task<T> GetAsync() { } and would be called from: public async Task<IEnumerable<T>> GetAllAsync() { foreach (var item in something)...

Having these three methods available in Rx.NET library public static IObservable<TResult> Create<TResult>(Func<IObserver<TResult>, CancellationToken, Task> subscribeAsync)...

I have one observable that I use GroupBy on to get a number of streams. I actually want a Scan result over each sub-stream. Let's say the observable is over product prices and the scan result is av...

I recently started working on Reactive Extensions, mostly observables at client side using Angular 2. The concept of observables of Rx and events of dotnet seems to be very similar. Are there...

I am new to RX and have been investigating error handling and the use of Retry; I have the following (yes I know it's not a 'real' unit test but it gives me place to fiddle!!) and was wondering how...

I have a game (based on MonoGame / XNA) with an update method like so: public void Update(GameTime gameTime) { component.Update(gameTime); } I would like to convert this to the Reactive patter...

I'm trying to parse an incoming stream of bytes that represents messages. I need to split the stream and create a message structure for each part. A message always starts with a 0x81 (BOM) and end...

Need: long-running program with TCP connections A C# 4.0 (VS1010, XP) program needs to connect to a host using TCP, send and receive bytes, sometimes close the connection properly and reopen it la...

I have a class which takes in a stream of events, and pushes out another stream of events. All of the events use Reactive Extensions (RX). The incoming stream of events is pushed from an external...

After reading the explanation for why Observable.Return(5) .Repeat() .Take(1) never completes, but Observable.Return(5, Scheduler.CurrentThread) .Repeat() .Take(1) works as expected. I am sti...