diff --git a/frontend/app/index.html b/frontend/app/index.html
index b6ab17916e..2ed1e175d3 100644
--- a/frontend/app/index.html
+++ b/frontend/app/index.html
@@ -294,6 +294,7 @@
     <script src="scripts/services/common/data/PSearchSrv.js"></script>
     <script src="scripts/services/common/data/SearchSrv.js"></script>
     <script src="scripts/services/common/data/StatSrv.js"></script>
+    <script src="scripts/services/common/data/StreamQuerySrv.js"></script>
     <script src="scripts/services/common/data/StreamSrv.js"></script>
     <script src="scripts/services/common/data/StreamStatSrv.js"></script>
     <script src="scripts/services/common/HtmlSanitizeSrv.js"></script>
diff --git a/frontend/app/scripts/controllers/case/CaseMainCtrl.js b/frontend/app/scripts/controllers/case/CaseMainCtrl.js
index c16b42a209..ee81c87e24 100644
--- a/frontend/app/scripts/controllers/case/CaseMainCtrl.js
+++ b/frontend/app/scripts/controllers/case/CaseMainCtrl.js
@@ -1,7 +1,7 @@
 (function() {
     'use strict';
     angular.module('theHiveControllers').controller('CaseMainCtrl',
-        function($scope, $rootScope, $state, $stateParams, $q, $uibModal, CaseTabsSrv, CaseSrv, UserSrv, MispSrv, StreamSrv, StreamStatSrv, NotificationSrv, UtilsSrv, CaseResolutionStatus, CaseImpactStatus, CortexSrv, caze) {
+        function($scope, $rootScope, $state, $stateParams, $q, $uibModal, CaseTabsSrv, CaseSrv, UserSrv, MispSrv, StreamSrv, StreamQuerySrv, StreamStatSrv, NotificationSrv, UtilsSrv, CaseResolutionStatus, CaseImpactStatus, CortexSrv, caze) {
             $scope.CaseResolutionStatus = CaseResolutionStatus;
             $scope.CaseImpactStatus = CaseImpactStatus;
             $scope.caseResponders = null;
@@ -81,46 +81,46 @@
                 }
             });
 
-            $scope.tasks = StreamStatSrv({
+            StreamQuerySrv('v1', [
+                {_name: 'getCase', idOrName: caseId},
+                {_name: 'tasks'},
+                {_name: 'filter',
+                    _not: {
+                        '_field': 'status',
+                        '_value': 'Cancel'
+                    }
+                },
+                {_name: 'count'}
+            ], {
                 scope: $scope,
                 rootId: caseId,
+                objectType: 'case_task',
                 query: {
-                    '_and': [{
-                        '_parent': {
-                            "_type": "case",
-                            "_query": {
-                                "_id": caseId
-                            }
-                        }
-                    }, {
-                        '_not': {
-                            'status': 'Cancel'
-                        }
-                    }]
+                    params: {
+                        name: 'task-stats-' + caseId
+                    }
                 },
-                result: {},
-                objectType: 'case_task',
-                field: 'status'
+                onUpdate: function(updates) {
+                    $scope.tasksCount = updates;
+                }
             });
 
-            $scope.artifactStats = StreamStatSrv({
+            StreamQuerySrv('v1', [
+                {_name: 'getCase', idOrName: caseId},
+                {_name: 'observables'},
+                {_name: 'count'}
+            ], {
                 scope: $scope,
                 rootId: caseId,
+                objectType: 'case_artifact',
                 query: {
-                    '_and': [{
-                        '_parent': {
-                            "_type": "case",
-                            "_query": {
-                                "_id": caseId
-                            }
-                        }
-                    }, {
-                        'status': 'Ok'
-                    }]
+                    params: {
+                        name: 'observable-stats-' + caseId
+                    }
                 },
-                result: {},
-                objectType: 'case_artifact',
-                field: 'status'
+                onUpdate: function(updates) {
+                    $scope.observableCount = updates;
+                }
             });
 
             $scope.alerts = StreamStatSrv({
diff --git a/frontend/app/scripts/services/common/data/StreamQuerySrv.js b/frontend/app/scripts/services/common/data/StreamQuerySrv.js
new file mode 100644
index 0000000000..7f08c58efd
--- /dev/null
+++ b/frontend/app/scripts/services/common/data/StreamQuerySrv.js
@@ -0,0 +1,24 @@
+(function() {
+    'use strict';
+    angular.module('theHiveServices')
+        .factory('StreamQuerySrv', function($http, StreamSrv, QuerySrv) {
+            return function(version, operations, config) {
+                StreamSrv.addListener({
+                    rootId: config.rootId,
+                    objectType: config.objectType,
+                    scope: config.scope,
+                    callback:function() {
+                        QuerySrv.query(version, operations, config.query)
+                            .then(function(response) {
+                                config.onUpdate(response.data);
+                            });
+                    }
+                });
+
+                QuerySrv.query(version, operations, config.query)
+                    .then(function(response) {
+                        config.onUpdate(response.data);
+                    });
+            };
+        });
+})();
diff --git a/frontend/app/views/app.case.html b/frontend/app/views/app.case.html
index 2fdeffc194..4a14ff4051 100644
--- a/frontend/app/views/app.case.html
+++ b/frontend/app/views/app.case.html
@@ -15,12 +15,12 @@
 
                             <span ng-switch-when="tasks">
                                 <i class="glyphicon glyphicon-tasks"></i>&nbsp;&nbsp;{{tab.label}}&nbsp;&nbsp;
-                                <span class="badge">{{tasks.count}}</span>
+                                <span class="badge">{{tasksCount}}</span>
                             </span>
 
                             <span ng-switch-when="observables">
                                 <i class="glyphicon glyphicon-pushpin"></i>&nbsp;&nbsp; Observables&nbsp;&nbsp;
-                                <span class="badge badge-primary">{{artifactStats.count}}</span>
+                                <span class="badge badge-primary">{{observableCount}}</span>
                             </span>
 
                             <span ng-switch-default>
diff --git a/frontend/app/views/partials/observables/list/observables.html b/frontend/app/views/partials/observables/list/observables.html
index a3a43f9a7d..823c37e8df 100644
--- a/frontend/app/views/partials/observables/list/observables.html
+++ b/frontend/app/views/partials/observables/list/observables.html
@@ -2,7 +2,7 @@
 <div class="col-md-12 mb-s clearfix">
     <div class="pull-left">
         <h4>
-            Observable List ({{artifacts.total || 0}} of {{artifactStats.count}})
+            Observable List ({{artifacts.total || 0}} of {{observableCount}})
             <small class="ml-xxs" ng-if="selection.artifacts.length > 0 ">
                 ({{selection.artifacts.length}} selected)
             </small>