Make VM event streams look like real dart streams.

runtime/observatory/tests/service/code_test.dart

Index: runtime/observatory/tests/service/code_test.dart
diff --git a/runtime/observatory/tests/service/code_test.dart b/runtime/observatory/tests/service/code_test.dart
index 28e2f862f94c958c53285da8dfdf3390bff93350..4c5cdd35d7f2a86b6af63113589e271837f997e3 100644
--- a/runtime/observatory/tests/service/code_test.dart
+++ b/runtime/observatory/tests/service/code_test.dart
@@ -34,11 +34,15 @@ var tests = [
   return isolate.rootLibrary.load().then((_) {
       // Set up a listener to wait for breakpoint events.
       Completer completer = new Completer();
-      isolate.vm.events.stream.listen((ServiceEvent event) {
-        if (event.kind == ServiceEvent.kPauseBreakpoint) {
-          print('Breakpoint reached');
-          completer.complete();
-        }
+      isolate.vm.getDebugEventStream().then((stream) {

[Cutch, 2015/07/07 23:16:09]

Replace with:

await isolate.addBreakpoint(script, line);
await hasStoppedAtBreakpoint(isolate);

?

[turnidge, 2015/07/08 20:23:39]

My preference is to modify the tests as little as possible and allow test
cleanup/refactoring to go in a different cl.

+        var subscription;
+        subscription = stream.listen((ServiceEvent event) {
+          if (event.kind == ServiceEvent.kPauseBreakpoint) {
+            print('Breakpoint reached');
+            subscription.cancel();
+            completer.complete();
+          }
+        });
       });
 
       // Add the breakpoint.