Refactor and update examples: remove deprecated operators, enhance usage of Select and Reduce, and add new example files for better clarity and organization

Author: rzeldent

EXTENSIONS.md

@@ -4,22 +4,6 @@ This document provides comprehensive documentation for all the new reactive exte
 
 ## 🔧 Advanced Operators
 
-### OperatorSelect
-Transforms each emitted value using a provided function.
-
-**Signature:**
-```c++
-template<typename Tdest> auto Select(Tdest (*selector)(T)) -> OperatorSelect<T, Tdest>&
-template<typename Tdest> auto SelectTo() -> OperatorSelect<T, Tdest>&
-```
-
-**Example:**
-```c++
-FromArray(values, size)
-.Select<float>([](int x) { return x * 2.5; })  // Convert int to float with scaling
-.Do([](float x) { Serial.println(x); });
-```
-
 ### OperatorDistinct
 Emits only values that haven't been seen before in the stream.
 
@@ -89,25 +73,6 @@ FromArray(values, size)
 - State machines
 - Progressive calculations
 
-### OperatorReduce
-Accumulates values and emits only the final result.
-
-**Signature:**
-```c++
-template<typename Tdest> auto ReduceToFinal(Tdest (*accumulator)(Tdest, T), Tdest seed) -> OperatorReduce<T, Tdest>&
-```
-
-**Example:**
-```c++
-float multiplyValues(float acc, int current) {
-    return acc * current;
-}
-
-FromArray(values, size)
-.ReduceToFinal<float>(multiplyValues, 1.0)  // Only final product
-.Do([](float x) { Serial.print("Final product: "); Serial.println(x); });
-```
-
 ### OperatorStartWith
 Emits specified values before beginning to emit values from the source observable.
 

examples/Accelerometer/Accelerometer.cpp

@@ -50,7 +50,7 @@ void setup()
 
 	// Step counter using scan operator
 	accelerometer
-	.Select(getMagnitude)
+	.Select<float>(getMagnitude)
 	.Where(magnitudeThreshold)
 	.DistinctUntilChanged()  // Only count distinct movements
 	.Do(printStepCount);

examples/AccelerometerExample/AccelerometerExample.cpp

@@ -46,7 +46,7 @@ void loop()
 
 	// Using ReduceToFinal - only emits the final accumulated result
 	FromArray(values, valuesLength)
-    .ReduceToFinal<float>(accumulateValues, 10.0f)
+    .Reduce(accumulateValues, 10.0f)
 	.DoAndFinally(printFinalResult, printComplete);
 
 	Serial.println();

examples/DistinctExample/DistinctExample.cpp

@@ -1,69 +0,0 @@
-/***************************************************
-Copyright (c) 2019 Luis Llamas
-(www.luisllamas.es)
-
-Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License
- ****************************************************/
-
-#ifndef _REACTIVEOPERATORREDUCE_h
-#define _REACTIVEOPERATORREDUCE_h
-
-template <typename Torig, typename Tdest>
-class OperatorReduce : public Operator<Torig, Tdest>
-{
-public:
-	typedef Tdest(*ReactiveReduceFunction)(Tdest, Torig);
-	
-	OperatorReduce(ReactiveReduceFunction function, Tdest initialValue);
-
-	void OnNext(Torig value) override;
-	void OnComplete() override;
-	void Reset() override;
-
-private:
-	ReactiveReduceFunction _function;
-	Tdest _accumulator;
-	Tdest _initialValue;
-	bool _hasValue;
-};
-
-template <typename Torig, typename Tdest>
-OperatorReduce<Torig, Tdest>::OperatorReduce(ReactiveReduceFunction function, Tdest initialValue)
-{
-	_function = function;
-	_initialValue = initialValue;
-	_accumulator = initialValue;
-	_hasValue = false;
-}
-
-template <typename Torig, typename Tdest>
-void OperatorReduce<Torig, Tdest>::OnNext(Torig value)
-{
-	// Accumulate the value but don't emit yet
-	_accumulator = _function(_accumulator, value);
-	_hasValue = true;
-}
-
-template <typename Torig, typename Tdest>
-void OperatorReduce<Torig, Tdest>::OnComplete()
-{
-	// Only emit the final accumulated result when the observable completes
-	if (_hasValue || _accumulator != _initialValue)
-	{
-		this->_childObservers.OnNext(_accumulator);
-	}
-	
-	// Forward the completion signal
-	Operator<Torig, Tdest>::OnComplete();
-}
-
-template <typename Torig, typename Tdest>
-void OperatorReduce<Torig, Tdest>::Reset()
-{
-	_accumulator = _initialValue;
-	_hasValue = false;
-}
-
-#endif