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

Side by Side Diff: mojo/dart/test/bindings_generation_test.dart

Issue 1414483010: Dart: Use a RawReceivePort to receive events for Mojo handles. (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Merge Created 5 years, 1 month 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
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 import 'dart:async'; 5 import 'dart:async';
6 import 'dart:isolate'; 6 import 'dart:isolate';
7 import 'dart:typed_data'; 7 import 'dart:typed_data';
8 import 'dart:convert'; 8 import 'dart:convert';
9 9
10 import 'package:_testing/expect.dart'; 10 import 'package:_testing/expect.dart';
(...skipping 285 matching lines...) Expand 10 before | Expand all | Expand 10 after
296 296
297 void closingProviderIsolate(core.MojoMessagePipeEndpoint endpoint) { 297 void closingProviderIsolate(core.MojoMessagePipeEndpoint endpoint) {
298 var provider = new ProviderImpl(endpoint); 298 var provider = new ProviderImpl(endpoint);
299 provider._stub.close(); 299 provider._stub.close();
300 } 300 }
301 301
302 Future<bool> runOnClosedTest() { 302 Future<bool> runOnClosedTest() {
303 var testCompleter = new Completer(); 303 var testCompleter = new Completer();
304 var pipe = new core.MojoMessagePipe(); 304 var pipe = new core.MojoMessagePipe();
305 var proxy = new sample.ProviderProxy.fromEndpoint(pipe.endpoints[0]); 305 var proxy = new sample.ProviderProxy.fromEndpoint(pipe.endpoints[0]);
306 proxy.impl.onError = () => testCompleter.complete(true); 306 proxy.impl.onError = (_) => testCompleter.complete(true);
307 Isolate.spawn(closingProviderIsolate, pipe.endpoints[1]); 307 Isolate.spawn(closingProviderIsolate, pipe.endpoints[1]);
308 return testCompleter.future.then((b) { 308 return testCompleter.future.then((b) {
309 Expect.isTrue(b); 309 Expect.isTrue(b);
310 }); 310 });
311 } 311 }
312 312
313 main() async { 313 main() async {
314 testSerializeStructs(); 314 testSerializeStructs();
315 testUnions(); 315 testUnions();
316 await testEnums(); 316 await testEnums();
317 await testCallResponse(); 317 await testCallResponse();
318 await testAwaitCallResponse(); 318 await testAwaitCallResponse();
319 await runOnClosedTest(); 319 await runOnClosedTest();
320 } 320 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698