Dart: Use a RawReceivePort to receive events for Mojo handles.

mojo/dart/test/bindings_generation_test.dart

 // Copyright 2014 The Chromium Authors. 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:isolate';
 import 'dart:typed_data';
 import 'dart:convert';
 
 import 'package:_testing/expect.dart';
 import 'package:mojo/bindings.dart' as bindings;
 import 'package:mojo/core.dart' as core;
 import 'package:mojom/sample/sample_interfaces.mojom.dart' as sample;
 import 'package:mojom/mojo/test/test_structs.mojom.dart' as structs;
 import 'package:mojom/mojo/test/test_unions.mojom.dart' as unions;
 import 'package:mojom/mojo/test/rect.mojom.dart' as rect;
-import 'package:mojom/mojo/test/serialization_test_structs.mojom.dart' as serialization;
-import 'package:mojom/regression_tests/regression_tests.mojom.dart' as regression;
+import 'package:mojom/mojo/test/serialization_test_structs.mojom.dart'
+    as serialization;
+import 'package:mojom/regression_tests/regression_tests.mojom.dart'
+    as regression;
 
 class ProviderImpl implements sample.Provider {
   sample.ProviderStub _stub;
 
   ProviderImpl(core.MojoMessagePipeEndpoint endpoint) {
     _stub = new sample.ProviderStub.fromEndpoint(endpoint, this);
   }
 
   echoString(String a, Function responseFactory) =>
       new Future.value(responseFactory(a));
@@ skipping 90 matching lines @@
     ..height = 4;
 
   var encodedRect = JSON.encode(r);
   var goldenEncoding = "{\"x\":1,\"y\":2,\"width\":3,\"height\":4}";
   Expect.equals(goldenEncoding, encodedRect);
 }
 
 testSerializeHandleToJSON() {
   var s = new serialization.Struct2();
 
-  Expect.throws(() => JSON.encode(s),
-    (e) => e.cause is bindings.MojoCodecError);
+  Expect.throws(
+      () => JSON.encode(s), (e) => e.cause is bindings.MojoCodecError);
 }
 
 testSerializeStructs() {
   testSerializeNamedRegion();
   testSerializeArrayValueTypes();
   testSerializeToJSON();
   testSerializeHandleToJSON();
 }
 
 testSerializePodUnions() {
-  var s = new unions.WrapperStruct()
-    ..podUnion = new unions.PodUnion();
+  var s = new unions.WrapperStruct()..podUnion = new unions.PodUnion();
   s.podUnion.fUint32 = 32;
 
   Expect.equals(unions.PodUnionTag.fUint32, s.podUnion.tag);
   Expect.equals(32, s.podUnion.fUint32);
 
   var message = messageOfStruct(s);
   var s2 = unions.WrapperStruct.deserialize(message.payload);
 
   Expect.equals(s.podUnion.fUint32, s2.podUnion.fUint32);
 }
 
 testSerializeStructInUnion() {
-  var s = new unions.WrapperStruct()
-    ..objectUnion = new unions.ObjectUnion();
-  s.objectUnion.fDummy = new unions.DummyStruct()
-    ..fInt8 = 8;
+  var s = new unions.WrapperStruct()..objectUnion = new unions.ObjectUnion();
+  s.objectUnion.fDummy = new unions.DummyStruct()..fInt8 = 8;
 
   var message = messageOfStruct(s);
   var s2 = unions.WrapperStruct.deserialize(message.payload);
 
   Expect.equals(s.objectUnion.fDummy.fInt8, s2.objectUnion.fDummy.fInt8);
 }
 
 testSerializeArrayInUnion() {
-  var s = new unions.WrapperStruct()
-    ..objectUnion = new unions.ObjectUnion();
+  var s = new unions.WrapperStruct()..objectUnion = new unions.ObjectUnion();
   s.objectUnion.fArrayInt8 = [1, 2, 3];
 
   var message = messageOfStruct(s);
   var s2 = unions.WrapperStruct.deserialize(message.payload);
 
   Expect.listEquals(s.objectUnion.fArrayInt8, s2.objectUnion.fArrayInt8);
 }
 
 testSerializeMapInUnion() {
-  var s = new unions.WrapperStruct()
-    ..objectUnion = new unions.ObjectUnion();
-  s.objectUnion.fMapInt8 = {
-    "one": 1,
-    "two": 2,
-  };
+  var s = new unions.WrapperStruct()..objectUnion = new unions.ObjectUnion();
+  s.objectUnion.fMapInt8 = {"one": 1, "two": 2,};
 
   var message = messageOfStruct(s);
   var s2 = unions.WrapperStruct.deserialize(message.payload);
 
   Expect.equals(1, s.objectUnion.fMapInt8["one"]);
   Expect.equals(2, s.objectUnion.fMapInt8["two"]);
 }
 
 testSerializeUnionInArray() {
   var s = new unions.SmallStruct()
     ..podUnionArray = [
-      new unions.PodUnion()
-        ..fUint16 = 16,
-      new unions.PodUnion()
-        ..fUint32 = 32,
+      new unions.PodUnion()..fUint16 = 16,
+      new unions.PodUnion()..fUint32 = 32,
     ];
 
   var message = messageOfStruct(s);
 
   var s2 = unions.SmallStruct.deserialize(message.payload);
 
   Expect.equals(16, s2.podUnionArray[0].fUint16);
   Expect.equals(32, s2.podUnionArray[1].fUint32);
 }
 
 testSerializeUnionInMap() {
   var s = new unions.SmallStruct()
     ..podUnionMap = {
-      'one': new unions.PodUnion()
-        ..fUint16 = 16,
-      'two': new unions.PodUnion()
-        ..fUint32 = 32,
+      'one': new unions.PodUnion()..fUint16 = 16,
+      'two': new unions.PodUnion()..fUint32 = 32,
     };
 
   var message = messageOfStruct(s);
 
   var s2 = unions.SmallStruct.deserialize(message.payload);
 
   Expect.equals(16, s2.podUnionMap['one'].fUint16);
   Expect.equals(32, s2.podUnionMap['two'].fUint32);
 }
 
 testSerializeUnionInUnion() {
-  var s = new unions.WrapperStruct()
-    ..objectUnion = new unions.ObjectUnion();
-    s.objectUnion.fPodUnion = new unions.PodUnion()
-        ..fUint32 = 32;
+  var s = new unions.WrapperStruct()..objectUnion = new unions.ObjectUnion();
+  s.objectUnion.fPodUnion = new unions.PodUnion()..fUint32 = 32;
 
   var message = messageOfStruct(s);
   var s2 = unions.WrapperStruct.deserialize(message.payload);
 
   Expect.equals(32, s2.objectUnion.fPodUnion.fUint32);
 }
 
 testUnionsToString() {
   var podUnion = new unions.PodUnion();
   podUnion.fUint32 = 32;
@@ skipping 55 matching lines @@
 
 void closingProviderIsolate(core.MojoMessagePipeEndpoint endpoint) {
   var provider = new ProviderImpl(endpoint);
   provider._stub.close();
 }
 
 Future<bool> runOnClosedTest() {
   var testCompleter = new Completer();
   var pipe = new core.MojoMessagePipe();
   var proxy = new sample.ProviderProxy.fromEndpoint(pipe.endpoints[0]);
-  proxy.impl.onError = () => testCompleter.complete(true);
+  proxy.impl.onError = (_) => testCompleter.complete(true);
   Isolate.spawn(closingProviderIsolate, pipe.endpoints[1]);
   return testCompleter.future.then((b) {
     Expect.isTrue(b);
   });
 }
 
 main() async {
   testSerializeStructs();
   testUnions();
   await testEnums();
   await testCallResponse();
   await testAwaitCallResponse();
   await runOnClosedTest();
 }