Index: runtime/observatory/lib/service_common.dart |
diff --git a/runtime/observatory/lib/service_common.dart b/runtime/observatory/lib/service_common.dart |
index 0580f5cdbd08a21802eca79a8dcfcfa3b043a504..0faa080bb8cc00abe77b3eca452d9434894e26a1 100644 |
--- a/runtime/observatory/lib/service_common.dart |
+++ b/runtime/observatory/lib/service_common.dart |
@@ -204,11 +204,11 @@ abstract class CommonWebSocketVM extends VM { |
bytes.offsetInBytes + offset, |
bytes.lengthInBytes - offset); |
var map = _parseJSON(meta); |
- if (map == null) { |
+ if (map == null || map['method'] != 'streamNotify') { |
return; |
} |
- var event = map['event']; |
- var streamId = map['streamId']; |
+ var event = map['params']['event']; |
+ var streamId = map['params']['streamId']; |
postServiceEvent(streamId, event, data); |
}); |
} |
@@ -218,9 +218,10 @@ abstract class CommonWebSocketVM extends VM { |
if (map == null) { |
return; |
} |
- var event = map['event']; |
- if (event != null) { |
- var streamId = map['streamId']; |
+ |
+ if (map['method'] == 'streamNotify') { |
+ var event = map['params']['event']; |
+ var streamId = map['params']['streamId']; |
postServiceEvent(streamId, event, null); |
return; |
} |