@@ -10,43 +10,38 @@ Unless required by applicable law or agreed to in writing, software distributed
10
10
#ifndef _REACTIVEOBSERVABLEANALOGINPUT_h
11
11
#define _REACTIVEOBSERVABLEANALOGINPUT_h
12
12
13
- template <typename T>
14
- class ObservableAnalogInput : public Observable <T>
13
+ class ObservableAnalogInput : public Observable <int >
15
14
{
16
15
public:
17
16
ObservableAnalogInput (uint8_t pin, uint8_t pinMode = INPUT);
18
- void Subscribe (IObserver<T > &observer) override ;
19
- void UnSubscribe (IObserver<T > &observer) override ;
17
+ void Subscribe (IObserver<int > &observer) override ;
18
+ void UnSubscribe (IObserver<int > &observer) override ;
20
19
21
20
void Next ();
22
21
23
22
private:
24
23
uint8_t _pin;
25
24
26
- ObserverList<T > _childObservers;
25
+ ObserverList<int > _childObservers;
27
26
};
28
27
29
- template <typename T>
30
- ObservableAnalogInput<T>::ObservableAnalogInput(uint8_t pin, uint8_t mode)
28
+ ObservableAnalogInput<int >::ObservableAnalogInput(uint8_t pin, uint8_t mode)
31
29
{
32
30
_pin = pin;
33
31
pinMode (pin, mode);
34
32
}
35
33
36
- template <typename T>
37
- void ObservableAnalogInput<T>::Subscribe(IObserver<T> &observer)
34
+ void ObservableAnalogInput<int >::Subscribe(IObserver<T> &observer)
38
35
{
39
36
this ->_childObservers .Add (&observer);
40
37
}
41
38
42
- template <typename T>
43
- void ObservableAnalogInput<T>::UnSubscribe(IObserver<T> &observer)
39
+ void ObservableAnalogInput<int >::UnSubscribe(IObserver<T> &observer)
44
40
{
45
41
this ->_childObservers .Remove (&observer);
46
42
}
47
43
48
- template <typename T>
49
- void ObservableAnalogInput<T>::Next()
44
+ void ObservableAnalogInput<int >::Next()
50
45
{
51
46
this ->_childObservers .OnNext (analogRead (_pin));
52
47
}
0 commit comments