Typo: Suscribe->Subscribe

rzeldent · rzeldent · commit 0029d776c54b · 2023-01-17T01:10:06.000+01:00
diff --git a/src/Observables/ObservableAnalogInput.h b/src/Observables/ObservableAnalogInput.h
@@ -15,7 +15,7 @@ class ObservableAnalogInput : public Observable<T>
 {
 public:
 	ObservableAnalogInput(uint8_t pin, uint8_t pinMode = INPUT);
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 	void Next();
 
 private:
@@ -32,7 +32,7 @@ ObservableAnalogInput<T>::ObservableAnalogInput(uint8_t pin, uint8_t mode)
 }
 
 template <typename T>
-void ObservableAnalogInput<T>::Suscribe(IObserver<T> &observer)
+void ObservableAnalogInput<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableArray.h b/src/Observables/ObservableArray.h
@@ -15,7 +15,7 @@ class ObservableArray : public Observable<T>
 {
 public:
 	ObservableArray(T *array, size_t length);
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 	void Run();
 	void Reset() override;
 
@@ -33,7 +33,7 @@ ObservableArray<T>::ObservableArray(T *array, size_t length)
 }
 
 template <typename T>
-void ObservableArray<T>::Suscribe(IObserver<T> &observer)
+void ObservableArray<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 	Run();
diff --git a/src/Observables/ObservableArrayDefer.h b/src/Observables/ObservableArrayDefer.h
@@ -15,7 +15,7 @@ class ObservableArrayDefer : public Observable<T>
 {
 public:
 	ObservableArrayDefer(T *array, size_t length);
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 	void Next();
 	void Reset() override;
 
@@ -36,7 +36,7 @@ ObservableArrayDefer<T>::ObservableArrayDefer(T *array, size_t length)
 }
 
 template <typename T>
-void ObservableArrayDefer<T>::Suscribe(IObserver<T> &observer)
+void ObservableArrayDefer<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableDigitalInput.h b/src/Observables/ObservableDigitalInput.h
@@ -15,7 +15,7 @@ class ObservableDigitalInput : public Observable<T>
 {
 public:
 	ObservableDigitalInput(uint8_t pin, uint8_t pinMode = INPUT);
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 	void Next();
 
 private:
@@ -32,7 +32,7 @@ ObservableDigitalInput<T>::ObservableDigitalInput(uint8_t pin, uint8_t mode)
 }
 
 template <typename T>
-void ObservableDigitalInput<T>::Suscribe(IObserver<T> &observer)
+void ObservableDigitalInput<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableIntervalMicros.h b/src/Observables/ObservableIntervalMicros.h
@@ -15,7 +15,7 @@ class ObservableIntervalMicros : public Observable<unsigned long>
 {
 public:
 	ObservableIntervalMicros(unsigned long microsInterval, unsigned long delay = 0);
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 
 	void Start();
 	void Reset() override;
@@ -52,7 +52,7 @@ ObservableIntervalMicros<T>::ObservableIntervalMicros(unsigned long interval, un
 }
 
 template <typename T>
-void ObservableIntervalMicros<T>::Suscribe(IObserver<T> &observer)
+void ObservableIntervalMicros<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableIntervalMillis.h b/src/Observables/ObservableIntervalMillis.h
@@ -15,7 +15,7 @@ class ObservableIntervalMillis : public Observable<unsigned long>
 {
 public:
 	ObservableIntervalMillis(unsigned long microsInterval, unsigned long delay = 0);
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 
 	void Start();
 	void Reset() override;
@@ -52,17 +52,17 @@ ObservableIntervalMillis<T>::ObservableIntervalMillis(unsigned long interval, un
 }
 
 template <typename T>
-void ObservableIntervalMillis<T>::Suscribe(IObserver<T> &observer)
+void ObservableIntervalMillis<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 }
 
 template <typename T>
 void ObservableIntervalMillis<T>::Update()
 {
-	if (_isActive == false) return;
-
-	auto elapsed = static_cast<unsigned long>(millis() - _startTime);
+	if (_isActive == false) return;
+
+	auto elapsed = static_cast<unsigned long>(millis() - _startTime);
 	if (elapsed >= _interval + _offset)
 	{
 		if (_childObserver != nullptr) _childObserver->OnNext(elapsed);
diff --git a/src/Observables/ObservableManualDefer.h b/src/Observables/ObservableManualDefer.h
@@ -15,7 +15,7 @@ class ObservableManualDefer : public Observable<T>
 {
 public:
 	ObservableManualDefer();
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 	void Next();
 	void Reset() override;
 	void Complete();
@@ -30,7 +30,7 @@ ObservableManualDefer<T>::ObservableManualDefer()
 }
 
 template <typename T>
-void ObservableManualDefer<T>::Suscribe(IObserver<T> &observer)
+void ObservableManualDefer<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableProperty.h b/src/Observables/ObservableProperty.h
@@ -16,7 +16,7 @@ class ObservableProperty : public Observable<T>
 public:
 	void operator = (const T&);
 	ObservableProperty();
-	void Suscribe(IObserver<T> &) override;
+	void Subscribe(IObserver<T> &) override;
 	void Finish();
 	void Reset() override;
 
@@ -38,7 +38,7 @@ ObservableProperty<T>::ObservableProperty()
 }
 
 template <typename T>
-void ObservableProperty<T>::Suscribe(IObserver<T> &observer)
+void ObservableProperty<T>::Subscribe(IObserver<T> &observer)
 {
 	this->_observer = &observer;
 }
diff --git a/src/Observables/ObservableRange.h b/src/Observables/ObservableRange.h
@@ -17,7 +17,7 @@ class ObservableRange : public Observable<T>
 {
 public:
 	ObservableRange(T start, T end, T step = 1);
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 	void Run();
 	void Reset() override;
 
@@ -38,7 +38,7 @@ ObservableRange<T>::ObservableRange(T start, T end, T step)
 }
 
 template <typename T>
-void ObservableRange<T>::Suscribe(IObserver<T> &observer)
+void ObservableRange<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 	Run();
diff --git a/src/Observables/ObservableRangeDefer.h b/src/Observables/ObservableRangeDefer.h
@@ -15,7 +15,7 @@ class ObservableRangeDefer : public Observable<T>
 {
 public:
 	ObservableRangeDefer(T start, T end, T step = 1);
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 	void Next();
 	void Reset() override;
 
@@ -38,7 +38,7 @@ ObservableRangeDefer<T>::ObservableRangeDefer(T start, T end, T step)
 }
 
 template <typename T>
-void ObservableRangeDefer<T>::Suscribe(IObserver<T> &observer)
+void ObservableRangeDefer<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableSerial.h b/src/Observables/ObservableSerial.h
@@ -15,7 +15,7 @@ class ObservableSerial : public Observable<T>
 {
 public:
 	ObservableSerial();
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 	virtual void Receive();
 
 private:
@@ -28,7 +28,7 @@ ObservableSerial<T>::ObservableSerial()
 }
 
 template <typename T>
-void ObservableSerial<T>::Suscribe(IObserver<T> &observer)
+void ObservableSerial<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableSerialByte.h b/src/Observables/ObservableSerialByte.h
@@ -15,7 +15,7 @@ class ObservableSerial<byte> : public Observable<byte>
 {
 public:
 	ObservableSerial();
-	void Suscribe(IObserver<byte> &observer);
+	void Subscribe(IObserver<byte> &observer);
 	void Receive();
 
 private:
@@ -26,7 +26,7 @@ ObservableSerial<byte>::ObservableSerial()
 {
 }
 
-void ObservableSerial<byte>::Suscribe(IObserver<byte> &observer)
+void ObservableSerial<byte>::Subscribe(IObserver<byte> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableSerialChar.h b/src/Observables/ObservableSerialChar.h
@@ -15,7 +15,7 @@ class ObservableSerial<char> : public Observable<char>
 {
 public:
 	ObservableSerial();
-	void Suscribe(IObserver<char> &observer) override;
+	void Subscribe(IObserver<char> &observer) override;
 	void Receive();
 
 private:
@@ -26,7 +26,7 @@ ObservableSerial<char>::ObservableSerial()
 {
 }
 
-void ObservableSerial<char>::Suscribe(IObserver<char> &observer)
+void ObservableSerial<char>::Subscribe(IObserver<char> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableSerialDouble.h b/src/Observables/ObservableSerialDouble.h
@@ -16,7 +16,7 @@ class ObservableSerial<double> : public Observable<double>
 {
 public:
 	ObservableSerial(char separator = '\n');
-	void Suscribe(IObserver<double> &observer) override;
+	void Subscribe(IObserver<double> &observer) override;
 	void Receive();
 
 private:
@@ -38,7 +38,7 @@ ObservableSerial<double>::ObservableSerial(char separator)
 	_separator = separator;
 }
 
-void ObservableSerial<double>::Suscribe(IObserver<double> &observer)
+void ObservableSerial<double>::Subscribe(IObserver<double> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableSerialFloat.h b/src/Observables/ObservableSerialFloat.h
@@ -16,7 +16,7 @@ class ObservableSerial<float> : public Observable<float>
 {
 public:
 	ObservableSerial(char separator = '\n');
-	void Suscribe(IObserver<float> &observer) override;
+	void Subscribe(IObserver<float> &observer) override;
 	void Receive() ;
 
 private:
@@ -38,7 +38,7 @@ ObservableSerial<float>::ObservableSerial(char separator)
 	_separator = separator;
 }
 
-void ObservableSerial<float>::Suscribe(IObserver<float> &observer)
+void ObservableSerial<float>::Subscribe(IObserver<float> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableSerialInteger.h b/src/Observables/ObservableSerialInteger.h
@@ -16,7 +16,7 @@ class ObservableSerial<int> : public Observable<int>
 {
 public:
 	ObservableSerial(char separator = '\n');
-	void Suscribe(IObserver<int> &observer) override;
+	void Subscribe(IObserver<int> &observer) override;
 	void Receive();
 
 private:
@@ -31,7 +31,7 @@ ObservableSerial<int>::ObservableSerial(char separator)
 	_separator = separator;
 }
 
-void ObservableSerial<int>::Suscribe(IObserver<int> &observer)
+void ObservableSerial<int>::Subscribe(IObserver<int> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableSerialString.h b/src/Observables/ObservableSerialString.h
@@ -15,7 +15,7 @@ class ObservableSerial<String> : public Observable<String>
 {
 public:
 	ObservableSerial(char separator = '\n');
-	void Suscribe(IObserver<String> &observer) override;
+	void Subscribe(IObserver<String> &observer) override;
 	void Receive();
 
 private:
@@ -29,7 +29,7 @@ ObservableSerial<String>::ObservableSerial(char separator)
 	_separator = separator;
 }
 
-void ObservableSerial<String>::Suscribe(IObserver<String> &observer)
+void ObservableSerial<String>::Subscribe(IObserver<String> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableTimerMicros.h b/src/Observables/ObservableTimerMicros.h
@@ -15,7 +15,7 @@ class ObservableTimerMicros : public Observable<unsigned long>
 {
 public:
 	ObservableTimerMicros(unsigned long microsInterval, unsigned long delay = 0);
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 
 	void Start();
 	void Reset() override;
@@ -52,7 +52,7 @@ ObservableTimerMicros<T>::ObservableTimerMicros(unsigned long interval, unsigned
 }
 
 template <typename T>
-void ObservableTimerMicros<T>::Suscribe(IObserver<T> &observer)
+void ObservableTimerMicros<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/Observables/ObservableTimerMillis.h b/src/Observables/ObservableTimerMillis.h
@@ -15,7 +15,7 @@ class ObservableTimerMillis : public Observable<unsigned long>
 {
 public:
 	ObservableTimerMillis(unsigned long microsInterval, unsigned long delay = 0);
-	void Suscribe(IObserver<T> &observer) override;
+	void Subscribe(IObserver<T> &observer) override;
 
 	void Start();
 	void Reset() override;
@@ -52,7 +52,7 @@ ObservableTimerMillis<T>::ObservableTimerMillis(unsigned long interval, unsigned
 }
 
 template <typename T>
-void ObservableTimerMillis<T>::Suscribe(IObserver<T> &observer)
+void ObservableTimerMillis<T>::Subscribe(IObserver<T> &observer)
 {
 	_childObserver = &observer;
 }
diff --git a/src/ReactiveArduinoBases.h b/src/ReactiveArduinoBases.h
@@ -49,7 +49,7 @@ template <typename T>
 class IObservable
 {
 public:
-	virtual void Suscribe(IObserver<T> &observer) = 0;
+	virtual void Subscribe(IObserver<T> &observer) = 0;
 
 protected:
 	virtual ~IObservable() = default;
diff --git a/src/ReactiveArduinoCore.h b/src/ReactiveArduinoCore.h

Original file line number	Diff line number	Diff line change
`@@ -15,7 +15,7 @@ class ObservableAnalogInput : public Observable<T>`
`15`	`15`	`{`
`16`	`16`	`public:`
`17`	`17`	`ObservableAnalogInput(uint8_t pin, uint8_t pinMode = INPUT);`
`18`		`- void Suscribe(IObserver<T> &observer) override;`
	`18`	`+ void Subscribe(IObserver<T> &observer) override;`
`19`	`19`	`void Next();`
`20`	`20`
`21`	`21`	`private:`
`@@ -32,7 +32,7 @@ ObservableAnalogInput<T>::ObservableAnalogInput(uint8_t pin, uint8_t mode)`
`32`	`32`	`}`
`33`	`33`
`34`	`34`	`template <typename T>`
`35`		`-void ObservableAnalogInput<T>::Suscribe(IObserver<T> &observer)`
	`35`	`+void ObservableAnalogInput<T>::Subscribe(IObserver<T> &observer)`
`36`	`36`	`{`
`37`	`37`	`_childObserver = &observer;`
`38`	`38`	`}`
Original file line number	Diff line number	Diff line change
`@@ -15,7 +15,7 @@ class ObservableArray : public Observable<T>`
`15`	`15`	`{`
`16`	`16`	`public:`
`17`	`17`	`ObservableArray(T *array, size_t length);`
`18`		`- void Suscribe(IObserver<T> &observer) override;`
	`18`	`+ void Subscribe(IObserver<T> &observer) override;`
`19`	`19`	`void Run();`
`20`	`20`	`void Reset() override;`
`21`	`21`
`@@ -33,7 +33,7 @@ ObservableArray<T>::ObservableArray(T *array, size_t length)`
`33`	`33`	`}`
`34`	`34`
`35`	`35`	`template <typename T>`
`36`		`-void ObservableArray<T>::Suscribe(IObserver<T> &observer)`
	`36`	`+void ObservableArray<T>::Subscribe(IObserver<T> &observer)`
`37`	`37`	`{`
`38`	`38`	`_childObserver = &observer;`
`39`	`39`	`Run();`
Original file line number	Diff line number	Diff line change
`@@ -15,7 +15,7 @@ class ObservableDigitalInput : public Observable<T>`
`15`	`15`	`{`
`16`	`16`	`public:`
`17`	`17`	`ObservableDigitalInput(uint8_t pin, uint8_t pinMode = INPUT);`
`18`		`- void Suscribe(IObserver<T> &observer) override;`
	`18`	`+ void Subscribe(IObserver<T> &observer) override;`
`19`	`19`	`void Next();`
`20`	`20`
`21`	`21`	`private:`
`@@ -32,7 +32,7 @@ ObservableDigitalInput<T>::ObservableDigitalInput(uint8_t pin, uint8_t mode)`
`32`	`32`	`}`
`33`	`33`
`34`	`34`	`template <typename T>`
`35`		`-void ObservableDigitalInput<T>::Suscribe(IObserver<T> &observer)`
	`35`	`+void ObservableDigitalInput<T>::Subscribe(IObserver<T> &observer)`
`36`	`36`	`{`
`37`	`37`	`_childObserver = &observer;`
`38`	`38`	`}`
Original file line number	Diff line number	Diff line change
`@@ -15,7 +15,7 @@ class ObservableIntervalMicros : public Observable<unsigned long>`
`15`	`15`	`{`
`16`	`16`	`public:`
`17`	`17`	`ObservableIntervalMicros(unsigned long microsInterval, unsigned long delay = 0);`
`18`		`- void Suscribe(IObserver<T> &observer) override;`
	`18`	`+ void Subscribe(IObserver<T> &observer) override;`
`19`	`19`
`20`	`20`	`void Start();`
`21`	`21`	`void Reset() override;`
`@@ -52,7 +52,7 @@ ObservableIntervalMicros<T>::ObservableIntervalMicros(unsigned long interval, un`
`52`	`52`	`}`
`53`	`53`
`54`	`54`	`template <typename T>`
`55`		`-void ObservableIntervalMicros<T>::Suscribe(IObserver<T> &observer)`
	`55`	`+void ObservableIntervalMicros<T>::Subscribe(IObserver<T> &observer)`
`56`	`56`	`{`
`57`	`57`	`_childObserver = &observer;`
`58`	`58`	`}`
Original file line number	Diff line number	Diff line change
`@@ -15,7 +15,7 @@ class ObservableManualDefer : public Observable<T>`
`15`	`15`	`{`
`16`	`16`	`public:`
`17`	`17`	`ObservableManualDefer();`
`18`		`- void Suscribe(IObserver<T> &observer) override;`
	`18`	`+ void Subscribe(IObserver<T> &observer) override;`
`19`	`19`	`void Next();`
`20`	`20`	`void Reset() override;`
`21`	`21`	`void Complete();`
`@@ -30,7 +30,7 @@ ObservableManualDefer<T>::ObservableManualDefer()`
`30`	`30`	`}`
`31`	`31`
`32`	`32`	`template <typename T>`
`33`		`-void ObservableManualDefer<T>::Suscribe(IObserver<T> &observer)`
	`33`	`+void ObservableManualDefer<T>::Subscribe(IObserver<T> &observer)`
`34`	`34`	`{`
`35`	`35`	`_childObserver = &observer;`
`36`	`36`	`}`
Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@ class ObservableProperty : public Observable<T>`
`16`	`16`	`public:`
`17`	`17`	`void operator = (const T&);`
`18`	`18`	`ObservableProperty();`
`19`		`- void Suscribe(IObserver<T> &) override;`
	`19`	`+ void Subscribe(IObserver<T> &) override;`
`20`	`20`	`void Finish();`
`21`	`21`	`void Reset() override;`
`22`	`22`
`@@ -38,7 +38,7 @@ ObservableProperty<T>::ObservableProperty()`
`38`	`38`	`}`
`39`	`39`
`40`	`40`	`template <typename T>`
`41`		`-void ObservableProperty<T>::Suscribe(IObserver<T> &observer)`
	`41`	`+void ObservableProperty<T>::Subscribe(IObserver<T> &observer)`
`42`	`42`	`{`
`43`	`43`	`this->_observer = &observer;`
`44`	`44`	`}`
Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ class ObservableRange : public Observable<T>`
`17`	`17`	`{`
`18`	`18`	`public:`
`19`	`19`	`ObservableRange(T start, T end, T step = 1);`
`20`		`- void Suscribe(IObserver<T> &observer) override;`
	`20`	`+ void Subscribe(IObserver<T> &observer) override;`
`21`	`21`	`void Run();`
`22`	`22`	`void Reset() override;`
`23`	`23`
`@@ -38,7 +38,7 @@ ObservableRange<T>::ObservableRange(T start, T end, T step)`
`38`	`38`	`}`
`39`	`39`
`40`	`40`	`template <typename T>`
`41`		`-void ObservableRange<T>::Suscribe(IObserver<T> &observer)`
	`41`	`+void ObservableRange<T>::Subscribe(IObserver<T> &observer)`
`42`	`42`	`{`
`43`	`43`	`_childObserver = &observer;`
`44`	`44`	`Run();`
Original file line number	Diff line number	Diff line change
`@@ -15,7 +15,7 @@ class ObservableRangeDefer : public Observable<T>`
`15`	`15`	`{`
`16`	`16`	`public:`
`17`	`17`	`ObservableRangeDefer(T start, T end, T step = 1);`
`18`		`- void Suscribe(IObserver<T> &observer) override;`
	`18`	`+ void Subscribe(IObserver<T> &observer) override;`
`19`	`19`	`void Next();`
`20`	`20`	`void Reset() override;`
`21`	`21`
`@@ -38,7 +38,7 @@ ObservableRangeDefer<T>::ObservableRangeDefer(T start, T end, T step)`
`38`	`38`	`}`
`39`	`39`
`40`	`40`	`template <typename T>`
`41`		`-void ObservableRangeDefer<T>::Suscribe(IObserver<T> &observer)`
	`41`	`+void ObservableRangeDefer<T>::Subscribe(IObserver<T> &observer)`
`42`	`42`	`{`
`43`	`43`	`_childObserver = &observer;`
`44`	`44`	`}`