| 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;
|
| }
|
|
|