diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Where.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Where.cs index 62320f39b8..9fe3daf392 100644 --- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Where.cs +++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Where.cs @@ -38,7 +38,7 @@ public _(Func predicate, IObserver observer) public override void OnNext(TSource value) { - var shouldRun = default(bool); + var shouldRun = false; try { shouldRun = _predicate(value); @@ -81,12 +81,11 @@ public _(Func predicate, IObserver observer) : base(observer) { _predicate = predicate; - _index = 0; } public override void OnNext(TSource value) { - var shouldRun = default(bool); + var shouldRun = false; try { shouldRun = _predicate(value, checked(_index++));