Merge pull request #1 from rzeldent/feature/multiple_subscribers

Feature/multiple subscribers

Author: rzeldent

.github/workflows/main.yml

@@ -0,0 +1,21 @@
+name: Platform IO CI
+on: [push]
+jobs:
+  build:
+    name: Build
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        pio-env: ['esp12e', 'esp32dev']
+        example: ['Blink/Blink.cpp', 'Do/Do.cpp', 'FromArray/FromArray.cpp', 'FromProperty/FromProperty.cpp', 'FromSerialPort/FromSerialPort.cpp', 'FromString/FromString.cpp', 'GlobalDefined/GlobalDefined.cpp', 'Reduce/Reduce.cpp']
+    steps:
+      - uses: actions/checkout@v2
+      - name: Set up python
+        uses: actions/setup-python@v2
+        with:
+          python-version: '3.x'
+          architecture: 'x64'
+      - name: Install PlatformIO
+        run: python -m pip install platformio
+      - name: Build firmware
+        run: pio ci --lib="." --board ${{matrix.pio-env}}  "examples/${{matrix.example}}"

examples/Blink/Blink.ino examples/Blink/Blink.cppexamples/Blink/Blink.ino renamed to examples/Blink/Blink.cpp

@@ -27,15 +27,15 @@ class AggregateAll : public Operator<T, bool>
 template <typename T>
 AggregateAll<T>::AggregateAll(ReactivePredicate<T> condition)
 {
-	this->_condition = condition;
+	_condition = condition;
 }
 
 template <typename T>
 void AggregateAll<T>::OnNext(T value)
 {
-	if (this->_state && this->_condition(value)) this->_state = false;
+	if (_state && _condition(value)) _state = false;
 
-	this->_childObserver->OnNext(_state);
+	this->_childObservers.OnNext(_state);
 }
 
 #endif