Dart: Refactor Stubs

mojo/dart/packages/_mojo_for_test_only/lib/mojo/test/test_unions.mojom.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.
 
 library test_unions_mojom;
 import 'dart:async';
 import 'dart:collection';
 import 'dart:convert';
 import 'dart:io';
 import 'dart:typed_data';
@@ skipping 2953 matching lines @@
   dynamic getAllTypeDefinitions([Function responseFactory]) =>
       responseFactory(null);
 }
 
 abstract class SmallCache {
   static const String serviceName = null;
   void setIntValue(int intValue);
   dynamic getIntValue([Function responseFactory = null]);
 }
 
-
-class _SmallCacheProxyControl extends bindings.ProxyMessageHandler
-                                      implements bindings.ProxyControl {
+class _SmallCacheProxyControl
+    extends bindings.ProxyMessageHandler
+    implements bindings.ProxyControl {
   _SmallCacheProxyControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
 
   _SmallCacheProxyControl.fromHandle(
       core.MojoHandle handle) : super.fromHandle(handle);
 
   _SmallCacheProxyControl.unbound() : super.unbound();
 
   service_describer.ServiceDescription get serviceDescription =>
       new _SmallCacheServiceDescription();
 
   String get serviceName => SmallCache.serviceName;
 
-  @override
   void handleResponse(bindings.ServiceMessage message) {
     switch (message.header.type) {
       case _smallCacheMethodGetIntValueName:
         var r = SmallCacheGetIntValueResponseParams.deserialize(
             message.payload);
         if (!message.header.hasRequestId) {
           proxyError("Expected a message with a valid request Id.");
           return;
         }
         Completer c = completerMap[message.header.requestId];
@@ skipping 16 matching lines @@
     }
   }
 
   @override
   String toString() {
     var superString = super.toString();
     return "_SmallCacheProxyControl($superString)";
   }
 }
 
-
-class SmallCacheProxy extends bindings.Proxy
-                              implements SmallCache {
+class SmallCacheProxy
+    extends bindings.Proxy
+    implements SmallCache {
   SmallCacheProxy.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint)
       : super(new _SmallCacheProxyControl.fromEndpoint(endpoint));
 
   SmallCacheProxy.fromHandle(core.MojoHandle handle)
       : super(new _SmallCacheProxyControl.fromHandle(handle));
 
   SmallCacheProxy.unbound()
       : super(new _SmallCacheProxyControl.unbound());
 
@@ skipping 24 matching lines @@
   dynamic getIntValue([Function responseFactory = null]) {
     var params = new _SmallCacheGetIntValueParams();
     return ctrl.sendMessageWithRequestId(
         params,
         _smallCacheMethodGetIntValueName,
         -1,
         bindings.MessageHeader.kMessageExpectsResponse);
   }
 }
 
-
-class SmallCacheStub extends bindings.Stub {
+class _SmallCacheStubControl
+    extends bindings.StubMessageHandler
+    implements bindings.StubControl<SmallCache> {
   SmallCache _impl;
 
-  SmallCacheStub.fromEndpoint(
+  _SmallCacheStubControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint, [SmallCache impl])
       : super.fromEndpoint(endpoint, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  SmallCacheStub.fromHandle(
+  _SmallCacheStubControl.fromHandle(
       core.MojoHandle handle, [SmallCache impl])
       : super.fromHandle(handle, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  SmallCacheStub.unbound([this._impl]) : super.unbound();
-
-  static SmallCacheStub newFromEndpoint(
-      core.MojoMessagePipeEndpoint endpoint) {
-    assert(endpoint.setDescription("For SmallCacheStub"));
-    return new SmallCacheStub.fromEndpoint(endpoint);
-  }
+  _SmallCacheStubControl.unbound([this._impl]) : super.unbound();
 
 
   SmallCacheGetIntValueResponseParams _smallCacheGetIntValueResponseParamsFactory(int intValue) {
     var result = new SmallCacheGetIntValueResponseParams();
     result.intValue = intValue;
     return result;
   }
 
   dynamic handleMessage(bindings.ServiceMessage message) {
     if (bindings.ControlMessageHandler.isControlMessage(message)) {
@@ skipping 49 matching lines @@
   }
 
   @override
   void bind(core.MojoMessagePipeEndpoint endpoint) {
     super.bind(endpoint);
     if (!isOpen && (_impl != null)) {
       beginHandlingEvents();
     }
   }
 
+  @override
   String toString() {
     var superString = super.toString();
-    return "SmallCacheStub($superString)";
+    return "_SmallCacheStubControl($superString)";
   }
 
   int get version => 0;
 
   static service_describer.ServiceDescription _cachedServiceDescription;
   static service_describer.ServiceDescription get serviceDescription {
     if (_cachedServiceDescription == null) {
       _cachedServiceDescription = new _SmallCacheServiceDescription();
     }
     return _cachedServiceDescription;
   }
 }
 
+class SmallCacheStub
+    extends bindings.Stub<SmallCache>
+    implements SmallCache {
+  SmallCacheStub.fromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint, [SmallCache impl])
+      : super(new _SmallCacheStubControl.fromEndpoint(endpoint, impl));
+
+  SmallCacheStub.fromHandle(
+      core.MojoHandle handle, [SmallCache impl])
+      : super(new _SmallCacheStubControl.fromHandle(handle, impl));
+
+  SmallCacheStub.unbound([SmallCache impl])
+      : super(new _SmallCacheStubControl.unbound(impl));
+
+  static SmallCacheStub newFromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint) {
+    assert(endpoint.setDescription("For SmallCacheStub"));
+    return new SmallCacheStub.fromEndpoint(endpoint);
+  }
+
+  static service_describer.ServiceDescription get serviceDescription =>
+      _SmallCacheStubControl.serviceDescription;
+
+
+  void setIntValue(int intValue) {
+    return impl.setIntValue(intValue);
+  }
+  dynamic getIntValue([Function responseFactory = null]) {
+    return impl.getIntValue(responseFactory);
+  }
+}
+
 const int _unionInterfaceMethodEchoName = 0;
 
 class _UnionInterfaceServiceDescription implements service_describer.ServiceDescription {
   dynamic getTopLevelInterface([Function responseFactory]) =>
       responseFactory(null);
 
   dynamic getTypeDefinition(String typeKey, [Function responseFactory]) =>
       responseFactory(null);
 
   dynamic getAllTypeDefinitions([Function responseFactory]) =>
       responseFactory(null);
 }
 
 abstract class UnionInterface {
   static const String serviceName = null;
   dynamic echo(PodUnion inVal,[Function responseFactory = null]);
 }
 
-
-class _UnionInterfaceProxyControl extends bindings.ProxyMessageHandler
-                                      implements bindings.ProxyControl {
+class _UnionInterfaceProxyControl
+    extends bindings.ProxyMessageHandler
+    implements bindings.ProxyControl {
   _UnionInterfaceProxyControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
 
   _UnionInterfaceProxyControl.fromHandle(
       core.MojoHandle handle) : super.fromHandle(handle);
 
   _UnionInterfaceProxyControl.unbound() : super.unbound();
 
   service_describer.ServiceDescription get serviceDescription =>
       new _UnionInterfaceServiceDescription();
 
   String get serviceName => UnionInterface.serviceName;
 
-  @override
   void handleResponse(bindings.ServiceMessage message) {
     switch (message.header.type) {
       case _unionInterfaceMethodEchoName:
         var r = UnionInterfaceEchoResponseParams.deserialize(
             message.payload);
         if (!message.header.hasRequestId) {
           proxyError("Expected a message with a valid request Id.");
           return;
         }
         Completer c = completerMap[message.header.requestId];
@@ skipping 16 matching lines @@
     }
   }
 
   @override
   String toString() {
     var superString = super.toString();
     return "_UnionInterfaceProxyControl($superString)";
   }
 }
 
-
-class UnionInterfaceProxy extends bindings.Proxy
-                              implements UnionInterface {
+class UnionInterfaceProxy
+    extends bindings.Proxy
+    implements UnionInterface {
   UnionInterfaceProxy.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint)
       : super(new _UnionInterfaceProxyControl.fromEndpoint(endpoint));
 
   UnionInterfaceProxy.fromHandle(core.MojoHandle handle)
       : super(new _UnionInterfaceProxyControl.fromHandle(handle));
 
   UnionInterfaceProxy.unbound()
       : super(new _UnionInterfaceProxyControl.unbound());
 
@@ skipping 15 matching lines @@
     var params = new _UnionInterfaceEchoParams();
     params.inVal = inVal;
     return ctrl.sendMessageWithRequestId(
         params,
         _unionInterfaceMethodEchoName,
         -1,
         bindings.MessageHeader.kMessageExpectsResponse);
   }
 }
 
-
-class UnionInterfaceStub extends bindings.Stub {
+class _UnionInterfaceStubControl
+    extends bindings.StubMessageHandler
+    implements bindings.StubControl<UnionInterface> {
   UnionInterface _impl;
 
-  UnionInterfaceStub.fromEndpoint(
+  _UnionInterfaceStubControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint, [UnionInterface impl])
       : super.fromEndpoint(endpoint, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  UnionInterfaceStub.fromHandle(
+  _UnionInterfaceStubControl.fromHandle(
       core.MojoHandle handle, [UnionInterface impl])
       : super.fromHandle(handle, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  UnionInterfaceStub.unbound([this._impl]) : super.unbound();
-
-  static UnionInterfaceStub newFromEndpoint(
-      core.MojoMessagePipeEndpoint endpoint) {
-    assert(endpoint.setDescription("For UnionInterfaceStub"));
-    return new UnionInterfaceStub.fromEndpoint(endpoint);
-  }
+  _UnionInterfaceStubControl.unbound([this._impl]) : super.unbound();
 
 
   UnionInterfaceEchoResponseParams _unionInterfaceEchoResponseParamsFactory(PodUnion outVal) {
     var result = new UnionInterfaceEchoResponseParams();
     result.outVal = outVal;
     return result;
   }
 
   dynamic handleMessage(bindings.ServiceMessage message) {
     if (bindings.ControlMessageHandler.isControlMessage(message)) {
@@ skipping 46 matching lines @@
   }
 
   @override
   void bind(core.MojoMessagePipeEndpoint endpoint) {
     super.bind(endpoint);
     if (!isOpen && (_impl != null)) {
       beginHandlingEvents();
     }
   }
 
+  @override
   String toString() {
     var superString = super.toString();
-    return "UnionInterfaceStub($superString)";
+    return "_UnionInterfaceStubControl($superString)";
   }
 
   int get version => 0;
 
   static service_describer.ServiceDescription _cachedServiceDescription;
   static service_describer.ServiceDescription get serviceDescription {
     if (_cachedServiceDescription == null) {
       _cachedServiceDescription = new _UnionInterfaceServiceDescription();
     }
     return _cachedServiceDescription;
   }
 }
 
+class UnionInterfaceStub
+    extends bindings.Stub<UnionInterface>
+    implements UnionInterface {
+  UnionInterfaceStub.fromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint, [UnionInterface impl])
+      : super(new _UnionInterfaceStubControl.fromEndpoint(endpoint, impl));
+
+  UnionInterfaceStub.fromHandle(
+      core.MojoHandle handle, [UnionInterface impl])
+      : super(new _UnionInterfaceStubControl.fromHandle(handle, impl));
+
+  UnionInterfaceStub.unbound([UnionInterface impl])
+      : super(new _UnionInterfaceStubControl.unbound(impl));
+
+  static UnionInterfaceStub newFromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint) {
+    assert(endpoint.setDescription("For UnionInterfaceStub"));
+    return new UnionInterfaceStub.fromEndpoint(endpoint);
+  }
+
+  static service_describer.ServiceDescription get serviceDescription =>
+      _UnionInterfaceStubControl.serviceDescription;
+
+
+  dynamic echo(PodUnion inVal,[Function responseFactory = null]) {
+    return impl.echo(inVal,responseFactory);
+  }
+}
+
 
 mojom_types.RuntimeTypeInfo getRuntimeTypeInfo() => _runtimeTypeInfo ??
     _initRuntimeTypeInfo();
 
 Map<String, mojom_types.UserDefinedType> getAllMojomTypeDefinitions() {
   return getRuntimeTypeInfo().typeMap;
 }
 
 var _runtimeTypeInfo;
 mojom_types.RuntimeTypeInfo  _initRuntimeTypeInfo() {
   // serializedRuntimeTypeInfo contains the bytes of the Mojo serialization of
   // a mojom_types.RuntimeTypeInfo struct describing the Mojom types in this
   // file. The string contains the base64 encoding of the gzip-compressed bytes.
   var serializedRuntimeTypeInfo = "H4sIAAAJbogC/+xdTXTbxhEGSVGmbDWm458wcdswTtMqSS3KP1XZtGnVZyuR0hdJjdyGfmkfBZGgKT2SYEgisdO+Vx9z7DFHH3v0MccefczRRx111NG3FgBnSOxgFwBhcAFLxnvwGtQQ2PnmZ2dnB8uCMjzy0C5BSz/HNkdaSneYGbaPzPO8eX4Hn38P7VNon0FbTA3bFWib0H4L7X+gfQLtIbT5NPQX2h1ov4X2MbRPoVWgX0Vo3zLP183zzt2t1eqfVu9+0Nb39cWB1h8s/rGz2jHa8LWfm+dP+XS3jXb7wfagZ9QGnnRraqfe0v7S2dM7ivKeSXOFT7feqbWM+l7nHt7TOt42z8t8+g3ta7ip4nnfzd19rTbY7LQejMm9+jukB1qP52+26uMbetBt6Q66d8zzJ3y67bbaat1Sa03N/Pu7ICMRndlJJ0xe/Nj0SLxs0iz60m3onQ2j1VJ3R3Kz7GJB8L3hVwy7U4icV/9t+s2GTdeH/r8PGHLo7/QeQH8cHHvc377vemeg9RpqTYP7W30vetBjdzzoPu+p3a7WG3ainBraN9r9QmrsB6z/7syMry0TfDzL/v3RK+zfK+fI9QX2+skl9vp+kVxfGV9bJv50iX3es9+w108+ZK9XPmGv85+y1web5O932eet/Z3tz/d1cv82318eQbuisAf64TK0/4OD0uFhwWlBjM6rAM+gbo0+f848s+ZZM88vzLNk9Hulll5TW6V7un6vpZWaelsrfdNTS9atSv1ebfifrrHb2quV9lDP+qXdvY7lvfol63HDf6uGrVSL1jfaI/7Tjuej/1/Aa8X7CIrTmuD7PwJ+P1r/bPsO+IxLHJwWgYDidRr6LwsvP1xSEeGC+rO9emtz47aivGn+/zUeLkBAcTkjGZciiT9yAEQx7Y3HCsFjS4DHeeCJGeRh7LrI4MJSUFzWzfOURFzQ3+QIv2XSr4wS7BDhqDhwdOqpSK8aVZOTshufT2LGp0BsKS+Ia9HQotIrJijk6hVLQfvzAeAqC7cyPA/5XQI8ymBva6BQFRj3d7J8v2713yI5iFjP8iDTRrVp40bx+i2MdTL1zHmIcDgM6MedOKQ4n+NxCWyuUW1r/b56T6t297qaW39+B/49DjxSHnhgPJSeAI+0w7/R48fmecHGo64OVBuMas3smtHWejw7/xBsMQ5c0gFwyUyAS2ZCXLo9vW7U+Lj8PkZcMgHsZ2YCXGY87MeyibM2Lv2m2tPq1V2j0TAhoXj8ATCKA48ZAR5ZBx7ZCfDIeuBxEWJmEw9relytwfyc4rECdLLjP4X0Az9/FWJ1JqkwQf6Bxpf5FJtfChoHVHz0jCZ9MC/lkxZy4f+vBMaZWUeeb9px5hz0RxXg8xD+nxT9RLsaSlcbZcg88i8MqV8cWxDg8Cyi+SLGW5iEfANsTpCedPXjG8nxK807KClxXMabH017HvQPyfYr4nsmZDwq4vss8GXzfW3Zxfc/QY9k6gGznpGK1p/TZLvbn3PT8a5+fSHZPqg/EcUXB1Oyi7qVRbnmxuFvQJMUvy3KCwVdJ5p2XoFZvOHmFVgK3vqfTL1bAf9QJusICxBn3QdH/AM4pkMIbIunkuW/ryXAf6cc9hmV/x7nVfqDntkryvf1BOZVnH5q0jyC/zhmeyqX/G8cMz/lN7+cNA8hml/iPK1R7cCCK388vAkykI1vSiK+6SnkM6wcz7yNr9rrqQ/Ae7nx/VWM+mvxQP02D5/MFPIbY/1rq90ROm58lgFLWfgscew7xelXhsYTPn4R8ZudAL9ZD/zQDhrVrl4fssHF79dAF7d/LJBxDYtTgtavTHs+jUU17vk0U27j6sdXCZwvxBGHfS05Dpu2PqDyufWBUUtXP16RrA9dyGc14fkVGDi3MF8KirAEA1sRHHgeHRHE80fQHoBi/TA3bP97Gur6ziRL384mJG+TiXgdcRw3WHxX9UGTvy6UTwj/p6YW7xu24Cnf5yTnrfzydZPG42Hzda8mhO9cyDjZf55r2IxTvs9LnueK+M6GjH8DyfvGdZe8LyRE3nMh49Zg8r5xnfJ9MSHyJsNjIL5PBZX38k2XvC8lRN6niZ0H4TsXWN7LNynfryVE3mmi70H4ngsk70ZLVwcueRcSIu8UkXsQvk8HknddN3vqqgd7PSHyxuPMBHyfCRSv7up6yx2vvZGAeM2Zn52fgO/5QHxro/p3J9+XJcvbL/9A6/WDvo8kqgfHdUy/eU/Q9SRR/QzWjQnKZly4N+E+cc3HCyS/6qyPcNYDVDJ8fI+es17FL2+2rQ3WO4O/qi1D4/Z/T4m3rh75z6eD820dorrDy8C7g++rPe1Lw+wMl388klY/PxtxXZNIT86B3zL5qH410hK+nlxQkldHL7KnQjrafAXa08c+9rSfEHs6UqK1p48Tak85sn7B0xcn3bT9D45fLF79rtlr7aX/Ce9/9iG2TJr/ofqEcdKjTDRxEr5vQV9KLsIzRa8tU/xqMaxbOOOfhymxvmWdjlqSvum7+47VRLe+1RNab0Hrr4K+Zy+y84zH/HZS3FPPsc6hKcl5Ty/twF1k32vz0dbVMZsIcOvqWAqK36eS8aN1dbiPRh4U6jtInC/AQPIYEoyVuWT4AVx/squtrNozAJ7iunHM6oImxT0X0g/4+V+2msON+ybIJ27cn7eeg4d32gPvQgi804r/+2YjvId1Wi68t0C34sAb67OynDhdkSSPnEAexRDy8HovEuM2rEasEsFQufxZ8rw7qFxk2Yno/a6FEHKZCbCO0RfYx2cQiyfdPqY5TmQ8/NZSCHkEeS90bB5ttcsZJ7Yhry27bjJF8g4FMp6K5vky/VrGw6+VQ8hr1sOv4T43HL9mC47icUfyfD4quUXt97zmIZY/WhPMQ/A9lkc+eastMg/pCuSH/fXcpMw8rirDd5wDbmvmwvNzJZnvEcvOP/jFvxXleNQzB32PmOp3IaB+rxH93hHgjvNp7mZ65ue/UIZ7Uvlsu+eSU/WlPgfKp+3EOL/gxUei92kn3ecyrH6PxuW5iPPEZPNHTp6YoaByWpCsz0ugrxiX/xtwKeA+r5BHKs9667vsfSAMgZ6/ewLyxl7zsqjzxlYOyFIBtaobPLzfA78e53tlYeZlsuQRNp/kL48mVx7vv6DyoPvlBd1vWTTveqZEm0/yk0dbYB+/jGmepQjWk5NgLxmJeaWxfPj2cvWYyCes/XjFT1mH3Gj8hPtl5WYmi58qHn7S6gvdDPsKyMdnu2yXXL+Meb39fioZ8RLOGzEvRHHqvVxfi3R9Ddc1O3qH2fGA4t5Xjtd+En7r+QXi32l/oq5vxvkY3SzfPR9jKaicLPSSUN88T1TY7/1s3AfgfiZaf4Lj6WqtqfP621Hirb9EvisT1hP62bPFr7Pw8kWoI5Q5zmB90V7HKiPk60X+BOdTo9ZLXJ8DvRwVuL7US/66sm7Y9a1cvXznBOnltPanQ31kfmxG4f3OBEtB+/OmIndfC5r/xLj9EOwU97t/6rHf/TT2TfTLcxaPWZ5TtF/WAZkvTDuf+dYJy2f64Z6WlLe8csLylqL9zxD3jKT85NsnPD/pJ4cZSXnIn53wPKRoffZhNtr4hPmRO258wlJQOd2SnFcsgj5iP/B3M4/Syag/wPmxbhvVuASB4nY7oXnGKNc1vHDPR5xnDFrHtKoc3zp+L7yLIddd/fR8+OtTYj3/KKF6Po31IWed/f8DAAD//7SFmZ9oeAAA";
 
   // Deserialize RuntimeTypeInfo
   var bytes = BASE64.decode(serializedRuntimeTypeInfo);
   var unzippedBytes = new ZLibDecoder().convert(bytes);
   var bdata = new ByteData.view(unzippedBytes.buffer);
   var message = new bindings.Message(bdata, null, unzippedBytes.length, 0);
   _runtimeTypeInfo = mojom_types.RuntimeTypeInfo.deserialize(message);
   test_included_unions_mojom.getAllMojomTypeDefinitions()
       .forEach((String s, mojom_types.UserDefinedType udt) {
           _runtimeTypeInfo.typeMap[s] = udt;
       });
 
   return _runtimeTypeInfo;
 }