Add the streamListen and streamCancel rpcs to the vm service.

runtime/vm/service_isolate.cc

 // 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.
 
 #include "vm/service_isolate.h"
 
 #include "vm/compiler.h"
 #include "vm/dart_api_impl.h"
 #include "vm/dart_entry.h"
 #include "vm/isolate.h"
@@ skipping 278 matching lines @@
     NativeArguments* arguments = reinterpret_cast<NativeArguments*>(args);
     Isolate* isolate = arguments->isolate();
     StackZone zone(isolate);
     HANDLESCOPE(isolate);
     {
       if (FLAG_trace_service) {
         OS::Print("vm-service: processed exit message.\n");
       }
     }
   }
+
+  static void ListenStream(Dart_NativeArguments args) {
+    NativeArguments* arguments = reinterpret_cast<NativeArguments*>(args);
+    Isolate* isolate = arguments->isolate();
+    StackZone stack_zone(isolate);
+    Zone* zone = stack_zone.GetZone();  // Used by GET_NON_NULL_NATIVE_ARGUMENT.
+    HANDLESCOPE(isolate);
+    GET_NON_NULL_NATIVE_ARGUMENT(String, stream_id, arguments->NativeArgAt(0));
+    Service::ListenStream(stream_id.ToCString());
+  }
+
+  static void CancelStream(Dart_NativeArguments args) {
+    NativeArguments* arguments = reinterpret_cast<NativeArguments*>(args);
+    Isolate* isolate = arguments->isolate();
+    StackZone stack_zone(isolate);
+    Zone* zone = stack_zone.GetZone();  // Used by GET_NON_NULL_NATIVE_ARGUMENT.
+    HANDLESCOPE(isolate);
+    GET_NON_NULL_NATIVE_ARGUMENT(String, stream_id, arguments->NativeArgAt(0));
+    Service::CancelStream(stream_id.ToCString());
+  }
 };
 
 
 struct ServiceNativeEntry {
   const char* name;
   int num_arguments;
   Dart_NativeFunction function;
 };
 
 
 static ServiceNativeEntry _ServiceNativeEntries[] = {
   {"VMService_SendIsolateServiceMessage", 2,
     ServiceIsolateNatives::SendIsolateServiceMessage},
   {"VMService_SendRootServiceMessage", 1,
     ServiceIsolateNatives::SendRootServiceMessage},
   {"VMService_OnStart", 0,
     ServiceIsolateNatives::OnStart },
   {"VMService_OnExit", 0,
     ServiceIsolateNatives::OnExit },
+  {"VMService_ListenStream", 1,
+    ServiceIsolateNatives::ListenStream },
+  {"VMService_CancelStream", 1,
+    ServiceIsolateNatives::CancelStream },
 };
 
 
 static Dart_NativeFunction ServiceNativeResolver(Dart_Handle name,
                                                  int num_arguments,
                                                  bool* auto_setup_scope) {
   const Object& obj = Object::Handle(Api::UnwrapHandle(name));
   if (!obj.IsString()) {
     return NULL;
   }
@@ skipping 447 matching lines @@
     return result;
   }
   Dart_Handle source = GetSource(url_string);
   if (Dart_IsError(source)) {
     return source;
   }
   return Dart_LoadSource(library, url, source, 0, 0);
 }
 
 }  // namespace dart