Why doesn't this pump the subscriber....

Question

Can anyone explain why the following subscriber is never called for this test method?

I would have thought the fact the second stream returned by the Complete<Unit>() method call completes immediately it would have pumped the CombineLatest.

        [Test]
        public void should_pump()
        {
            var sync = new ManualResetEvent(false);

            Observable.Return(Unit.Default)
                      .CombineLatest(Complete<Unit>(), (a, b) => new { a, b })
                      .Subscribe(
                          _ =>
                              {
                                  Debug.WriteLine("Subscriber called...");

                                  sync.Set();

                              });

            Debug.WriteLine("Waiting...");
            sync.WaitOne();
        }

        private IObservable<T> Complete<T>()
        {
            return Observable.Create<T>(o =>
            {
                o.OnCompleted();
                return Disposable.Empty;
            });
        }

ta

Ollie

---

Trying to remember what I learnt yesterday

Answer 1

Hi Ollie,

If that were true, then what value would you expect to be passed in as the b argument?

In other words, there's nothing to combine the left side with since the right side never calls OnNext.

- Dave

---

http://davesexton.com/blog