add sendRequest to VMIsolateRef

lib/src/isolate.dart

 // Copyright (c) 2015, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'package:async/async.dart';
 import 'package:crypto/crypto.dart';
 import 'package:json_rpc_2/json_rpc_2.dart' as rpc;
 
 import 'breakpoint.dart';
 import 'error.dart';
 import 'exceptions.dart';
 import 'library.dart';
 import 'pause_event.dart';
 import 'scope.dart';
 import 'sentinel.dart';
 import 'stack.dart';
 import 'stream_manager.dart';
 import 'utils.dart';
+import 'extension.dart';
 
 VMIsolateRef newVMIsolateRef(rpc.Peer peer, StreamManager streams, Map json) {
   if (json == null) return null;
   assert(json["type"] == "@Isolate" || json["type"] == "Isolate");
   var scope = new Scope(peer, streams, json["id"]);
   return new VMIsolateRef._(scope, json);
 }
 
 /// A reference to an isolate on the remote VM.
 ///
@@ skipping 47 matching lines @@
   /// [sdk#24351]: https://github.com/dart-lang/sdk/issues/24351
   Stream<List<int>> get stdout => _stdout;
   Stream<List<int>> _stdout;
 
   /// A broadcast stream that emits this isolate's standard error.
   ///
   /// This is only usable for embedders that provide access to `dart:io`.
   Stream<List<int>> get stderr => _stderr;
   Stream<List<int>> _stderr;
 
+  /// A broadcast stream that emits the name of VM service extensions
+  Stream<VMServiceExtension> get onServiceExtensionAdded =>
+      _onServiceExtensionAdded;
+  Stream<VMServiceExtension> _onServiceExtensionAdded;
+
   /// A future that fires when the isolate exits.
   ///
   /// If the isolate has already exited, this will complete immediately.
   Future get onExit => _onExitMemo.runOnce(() async {
     try {
       await _scope.getInState(_scope.streams.isolate, () async {
         try {
           await load();
           return null;
         } on VMSentinelException catch (_) {
@@ skipping 20 matching lines @@
         name = json["name"] {
     _onGC = _transform(_scope.streams.gc, (json, sink) {
       if (json["kind"] == "GC") sink.add(null);
     });
 
     _onUpdate = _transform(_scope.streams.isolate, (json, sink) {
       if (json["kind"] != "IsolateUpdate") return;
       sink.add(new VMIsolateRef._(_scope, json["isolate"]));
     });
 
+    _onServiceExtensionAdded = _transform(_scope.streams.isolate, (json, sink) {
+      if (json["kind"] != "ServiceExtensionAdded") return;
+      sink.add(newVMServiceExtension(json["extensionRPC"]));
+    });
+
     _onPauseOrResume = _transform(_scope.streams.debug, (json, sink) {
       var event = newVMPauseEvent(_scope, json);
       if (event != null) sink.add(event);
     });
 
     _onBreakpointAdded = _transform(_scope.streams.debug, (json, sink) {
       if (json["kind"] != "BreakpointAdded") return;
       sink.add(newVMBreakpoint(_scope, json["breakpoint"]));
     });
 
@@ skipping 118 matching lines @@
       var response = await _scope.sendRequest(
           "addBreakpointWithScriptUri", params);
       return newVMBreakpoint(_scope, response);
     } on rpc.RpcException catch (error) {
       // Error 102 indicates that the breakpoint couldn't be created.
       if (error.code == 102) return null;
       rethrow;
     }
   }
 
+  /// Makes a raw RPC to a VM service extension registered in this isolate
+  /// corresponding to the ID [number].
+  ///
+  /// [method] must correspond to a VM service extension installed on the VM
+  /// isolate and it must begin with prefix "ext.".
+  ///
+  /// [params] are passed to the extension handler and must be serializable to
+  /// a JSON string.
+  Future<Object> invokeExtension(String method, [Map<String, String> params]) {
+    if (!method.startsWith('ext.')) {
+      throw new ArgumentError.value(method, 'method',
+          'must begin with "ext." prefix');
+    }
+    return _scope.sendRequest(method, params);
+  }
+
   bool operator ==(other) => other is VMIsolateRef &&
       other._scope.isolateId == _scope.isolateId;
 
   int get hashCode => _scope.isolateId.hashCode;
 
   String toString() => name;
 }
 
 /// A full isolate on the remote VM.
 class VMIsolate extends VMIsolateRef {

[nweiz, 2016/02/16 22:03:20]

Could you add VMIsolate.extensionRpcs as well?

[yjbanov, 2016/02/16 22:31:49]

Done.

   /// The time that the isolate started running.
   final DateTime startTime;
 
   /// The number of live ports on this isolate.
   final int livePorts;
 
   /// Whether this isolate will pause before it exits.
   final bool pauseOnExit;
 
   /// The last pause event delivered to this isolate.
@@ skipping 71 matching lines @@
 
   /// The isolate continues until it exits the current function.
   static const out = const VMStep._("Out");
 
   /// The string name of the step type.
   final String _value;
 
   const VMStep._(this._value);
 
   String toString() => _value;
-}
+}