Deadlock between OnComplete & TakeUntil

I have encountered a deadlock in RX in a place I wasn't really expecting, I know RX isn't always naturally thread safe, but I feel here it maybe needs to be. I have a service that exposes a strea...

Id #89 | Release: None | Updated: May 7 at 9:01 AM by HenryTon | Created: May 7 at 9:01 AM by HenryTon

.

.

Id #88 | Release: None | Updated: May 5 at 9:34 PM by stellabass | Created: May 5 at 9:30 PM by stellabass

[EXTENDED] FOREVERMORE APRIL 1 2015 full episode replay

Watch Forevermore April 1 2015 Full Episode 04-01-2015, Forevermore April 1 2015 Full Episode 04-01-2015 Forevermore April 1 2015 Full Episode 04-01-2015 Forevermore April 1 2015 Full Episode 04-01...

Id #87 | Release: None | Updated: Apr 1 at 9:50 PM by Smial1942 | Created: Apr 1 at 9:50 PM by Smial1942

NullRef in ImmutableList.IndexOf

I get the below stacktrace in IndexOf. I believe the offending line is: "if (data[i].Equals(value))"; seems to be that there is a null at index 'i' -- probably should be "if (Equals(data[i], value)...

Id #86 | Release: None | Updated: Mar 10 at 3:07 AM by JoeTrainerRoad | Created: Mar 9 at 10:22 PM by tah9m9

Rx.Net ToTask throws TaskCanceledException missing CancellationToken

The method ToTask<TResult>(this IObservable<TResult> observable, CancellationToken cancellationToken, object state) in TaskObservableExtensions calls tcs.TrySetCanceled without passing the Cancella...

Id #85 | Release: None | Updated: Jan 27 at 9:22 AM by Lukazoid | Created: Jan 26 at 11:22 AM by Lukazoid

Sample operator has too much locking

The Sample<T> operator takes out a lock when it receives a value and also when it ticks and pumps the sampled value to its observers. This prevents the value from being changed while observers are...

Id #84 | Release: None | Updated: Jan 5 at 3:48 PM by john_rayner | Created: Jan 5 at 3:48 PM by john_rayner

Topological Order

Hi, Rx could propagate notifications in topological order in order to automatically minimize the amount of notifications/updates. It would brilliantly leverage the knowledge about the observable-...

Id #83 | Release: None | Updated: Nov 25, 2014 at 11:23 AM by davedev | Created: Nov 25, 2014 at 8:09 AM by jeromerg

Backpressure and Unbounded Queues

The problems of backpressure (fast producer, slow consumer) and unbounded queues in native operators (e.g., Zip, GroupBy, Merge) appear to be solved in a general way in RxJava by incorporating a Pr...

Id #82 | Release: None | Updated: Oct 9, 2014 at 3:40 PM by davedev | Created: Oct 6, 2014 at 10:22 PM by davedev

LocalScheduler work stealing bug

I discovered a bug in the LocalScheduler which is affecting one of our applications. The app makes use of ThreadPoolScheduler and DispatcherScheduler, which both inherit from the LocalScheduler bas...

Id #81 | Release: None | Updated: Nov 13, 2014 at 9:48 PM by mstrobel | Created: Sep 9, 2014 at 11:35 PM by ngm_codeplex

NullReferenceException in TestScheduler

Using version 2.2.4.0 with .net 4.5.1. TestScheduler throws a NullReferenceException when using it with multi-threaded access, however this is not in the TestScheduler itself, but the VirtualTim...

Id #79 | Release: None | Updated: Oct 9, 2014 at 3:49 PM by davedev | Created: Jul 24, 2014 at 7:14 PM by AGBrown