Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(270)

Side by Side Diff: runtime/observatory/tests/service/source_location_test.dart

Issue 1143783003: Add the streamListen and streamCancel rpcs to the vm service. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: before commit Created 5 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 // VMOptions=--compile-all --error_on_bad_type --error_on_bad_override 4 // VMOptions=--compile-all --error_on_bad_type --error_on_bad_override
5 5
6 import 'package:observatory/service_io.dart'; 6 import 'package:observatory/service_io.dart';
7 import 'package:observatory/debugger.dart'; 7 import 'package:observatory/debugger.dart';
8 import 'package:unittest/unittest.dart'; 8 import 'package:unittest/unittest.dart';
9 import 'test_helper.dart'; 9 import 'test_helper.dart';
10 import 'dart:async'; 10 import 'dart:async';
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after
49 }); 49 });
50 } 50 }
51 51
52 var tests = [ 52 var tests = [
53 53
54 // Bring the isolate to a breakpoint at line 15. 54 // Bring the isolate to a breakpoint at line 15.
55 (Isolate isolate) { 55 (Isolate isolate) {
56 return isolate.rootLibrary.load().then((_) { 56 return isolate.rootLibrary.load().then((_) {
57 // Listen for breakpoint event. 57 // Listen for breakpoint event.
58 Completer completer = new Completer(); 58 Completer completer = new Completer();
59 isolate.vm.events.stream.listen((ServiceEvent event) { 59 isolate.vm.debugEvents.listen((ServiceEvent event) {
60 if (event.eventType == ServiceEvent.kPauseBreakpoint) { 60 if (event.eventType == ServiceEvent.kPauseBreakpoint) {
61 completer.complete(); 61 completer.complete();
62 } 62 }
63 }); 63 });
64 64
65 // Add the breakpoint. 65 // Add the breakpoint.
66 var script = isolate.rootLibrary.scripts[0]; 66 var script = isolate.rootLibrary.scripts[0];
67 return isolate.addBreakpoint(script, 15).then((ServiceObject bpt) { 67 return isolate.addBreakpoint(script, 15).then((ServiceObject bpt) {
68 return completer.future; // Wait for breakpoint events. 68 return completer.future; // Wait for breakpoint events.
69 }); 69 });
(...skipping 202 matching lines...) Expand 10 before | Expand all | Expand 10 after
272 return SourceLocation.complete(debugger, 'SourceLocationTestFoo.q') 272 return SourceLocation.complete(debugger, 'SourceLocationTestFoo.q')
273 .then((List<String> completions) { 273 .then((List<String> completions) {
274 expect(completions.toString(), equals('[]')); 274 expect(completions.toString(), equals('[]'));
275 }); 275 });
276 }); 276 });
277 }, 277 },
278 278
279 ]; 279 ];
280 280
281 main(args) => runIsolateTests(args, tests, testeeConcurrent: testFunction); 281 main(args) => runIsolateTests(args, tests, testeeConcurrent: testFunction);
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698