/
example5.js
42 lines (35 loc) · 1010 Bytes
/
example5.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
import { Observable } from 'rxjs';
import { map } from 'rxjs/operators';
import {
writeTextInElement,
addChangeEventListenerToElement,
getElementValueFromEvent
} from '../utils/functions';
export function initialize () {
const customObservable = new Observable(configureObserver)
.pipe(
map(doubleValue)
);
const subscription = customObservable
.subscribe(
(value) => writeTextInElement(value, '.text_5'),
(error) => writeTextInElement(error, '.text_5'),
() => writeTextInElement('COMPLETED', '.text_5')
);
return [ customObservable, subscription ];
}
function configureObserver (observer) {
addChangeEventListenerToElement('.input_5', (event) => {
const value = getElementValueFromEvent(event);
if (value === 'END') {
observer.complete();
} else if (!isNaN(value)) {
observer.next(value);
} else {
observer.error('CRITICAL ERROR: Not a number!');
}
});
}
function doubleValue (value) {
return value * 2;
}