Add a controller that will watch for a stream to get set on the scope…

… as eventStream. We then subscribe to the stream and update scope variables based on events.

js/controllers/controllers.module.js

@@ -2,7 +2,10 @@
 
 var angular = require('angular');
 
+var eventConsumerModule = require('./eventConsumer/eventConsumer.controller');
+
 exports.moduleName = 'exp-ang.controllers';
 
 angular.module(exports.moduleName, [
+	eventConsumerModule.moduleName,
 ]);

js/controllers/eventConsumer/eventConsumer.controller.js

@@ -0,0 +1,31 @@
+'use strict';
+
+var angular = require('angular');
+
+exports.moduleName = 'exp-ang.controllers.eventConsumer';
+exports.controllerName = 'EventConsumerController';
+
+EventConsumerController.$inject = ['$scope'];
+function EventConsumerController($scope) {
+	var self = this;
+	var oldSubscription;
+
+	self.hitCount = 0;
+
+	$scope.$watch('eventStream', function(newValue) {
+		if (oldSubscription) {
+			oldSubscription.dispose();
+		}
+
+		oldSubscription = newValue.subscribe(function(data) {
+			$scope.$apply(function() { self.hitCount++; });
+		}, function(error) {
+			$scope.$apply(function() { self.error = error; });
+		}, function() {
+			$scope.$apply(function() { self.finished = true; });
+		});
+	});
+}
+
+angular.module(exports.moduleName, [])
+	.controller(exports.controllerName, EventConsumerController);