Last active
October 4, 2015 18:30
-
-
Save Cfeusier/6aedc496b590665ae78e to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| var count = 0, | |
| btnCount = document.getElementById('clicker'), | |
| btnEnd = document.getElementById('ender'), | |
| endO = Rx.Observable.fromEvent(btnEnd, 'click'); | |
| function counter() { | |
| console.log(++count); | |
| } | |
| function resultLogger() { | |
| alert( | |
| 'Final Count is ' + | |
| count + | |
| '\n Button clicks are not being counted from this point forward.' | |
| ); | |
| } | |
| // no need to keep reference to subscription because .dispose will be called | |
| // automatically when the endO .onNext method is called | |
| Rx.Observable | |
| // create Observable from 'click' event on the btnCount element | |
| .fromEvent(btnCount, 'click') | |
| // take data from Observable until endO.onNext is called | |
| .takeUntil(endO) | |
| // subscribe to Observable with two handlers - .onNext (increases count) and .onCompleted (logs results) | |
| .subscribe({ | |
| onNext: counter, | |
| onCompleted: resultLogger | |
| }); |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment