Fixed typo / forgot to remove

Author: rzeldent

src/Observables/ObservableArrayDefer.h

@@ -57,7 +57,7 @@ void ObservableArrayDefer<T>::Next()
 	this->_childObservers.OnNext(value);
 	_index++;
 
-	if(_index >= _length)
+	if (_index >= _length)
 		this->_childObservers.OnComplete();
 }
 

src/Observables/ObservableRangeDefer.h

@@ -59,7 +59,7 @@ void ObservableRangeDefer<T>::Next()
 	this->_childObservers.OnNext(value);
 	_value += _step;
 
-	if(_value > _end)
+	if (_value > _end)
 		this->_childObservers.OnComplete();
 }
 

src/Operators/OperatorFirst.h

@@ -34,7 +34,7 @@ OperatorFirst<T>::OperatorFirst()
 template <typename T>
 void OperatorFirst<T>::OnNext(T value)
 {
-	if(!_any) 
+	if (!_any) 
 		_first = value;
 
 	_any = true;

src/Operators/OperatorSkipWhile.h

@@ -36,7 +36,7 @@ void OperatorSkipWhile<T>::OnNext(T value)
 	if (!_started && !this->_condition(value))
 		_started = true;
 
-	if(_started == true)
+	if (_started == true)
 		this->_childObservers.OnNext(value);
 }
 

src/Operators/OperatorWhere.h

@@ -33,8 +33,7 @@ OperatorWhere<T>::OperatorWhere(ReactivePredicate<T> condition)
 template <typename T>
 void OperatorWhere<T>::OnNext(T value)
 {
-	if (this->_childObserver != nullptr)
-		if (this->_condition(value))
+		if (_condition(value))
 			this->_childObservers.OnNext(value);
 }
 

src/ReactiveArduinoCore.h

@@ -1041,7 +1041,7 @@ void Operator<Torig, Tdest>::OnComplete()
 template<typename Torig, typename Tdest>
 void Operator<Torig, Tdest>::Reset()
 {
-	if(_parentObservable != nullptr) _parentObservable->Reset();
+	if (_parentObservable != nullptr) _parentObservable->Reset();
 	_childObservers.RemoveAll();
 }
 #endif