Add reactive stream operators to demonstrate how event streams can be…

… decorated.
SonofNun15 · Nov 4, 2015 · f0c096c · f0c096c
1 parent 3919002
commit f0c096c
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/index.html b/index.html
@@ -12,6 +12,10 @@
 				<label>Hit count: </label>
 				<span>{{controller.hitCount}}</span>
 			</div>
+			<div>
+				<label>X pos: </label>
+				<span>{{controller.xPos}}</span>
+			</div>
 			<div>
 				<label>Error: </label>
 				<span>{{controller.error}}</span>

diff --git a/js/controllers/eventConsumer/eventConsumer.controller.js b/js/controllers/eventConsumer/eventConsumer.controller.js
@@ -17,8 +17,14 @@ function EventConsumerController($scope) {
 			oldSubscription.dispose();
 		}
 
-		oldSubscription = newValue.subscribe(function(data) {
-			$scope.$apply(function() { self.hitCount++; });
+		var xCoordStream = newValue.map(function(event) {
+			return {
+				position: event.offsetX,
+			};
+		}).sample(1000 /*ms*/);
+
+		oldSubscription = xCoordStream.subscribe(function(data) {
+			$scope.$apply(function() { self.hitCount++; self.xPos = data.position; });
 		}, function(error) {
 			$scope.$apply(function() { self.error = error; });
 		}, function() {