Show More
@@ -7043,15 +7043,17 b' function ChannelstreamController($rootScope, stateHolder, userSelfPropertyResour' | |||||
7043 | }; |
|
7043 | }; | |
7044 | stateHolder.websocket.onmessage = function (event) { |
|
7044 | stateHolder.websocket.onmessage = function (event) { | |
7045 | var data = JSON.parse(event.data); |
|
7045 | var data = JSON.parse(event.data); | |
7046 |
|
|
7046 | $scope.$apply(function (scope) { | |
7047 |
|
7047 | _.each(data, function (message) { | ||
7048 | if(typeof message.message.topic !== 'undefined'){ |
|
7048 | ||
7049 | $rootScope.$broadcast( |
|
7049 | if(typeof message.message.topic !== 'undefined'){ | |
7050 | 'channelstream-message.'+message.message.topic, message); |
|
7050 | $rootScope.$broadcast( | |
7051 | } |
|
7051 | 'channelstream-message.'+message.message.topic, message); | |
7052 |
|
|
7052 | } | |
7053 | $rootScope.$broadcast('channelstream-message', message); |
|
7053 | else{ | |
7054 | } |
|
7054 | $rootScope.$broadcast('channelstream-message', message); | |
|
7055 | } | |||
|
7056 | }); | |||
7055 | }); |
|
7057 | }); | |
7056 | }; |
|
7058 | }; | |
7057 | stateHolder.websocket.onclose = function (event) { |
|
7059 | stateHolder.websocket.onclose = function (event) { |
General Comments 0
You need to be logged in to leave comments.
Login now