Dart: Refactor Stubs

mojo/dart/packages/_mojo_for_test_only/lib/dart_to_cpp/dart_to_cpp.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 dart_to_cpp_mojom;
 import 'dart:async';
 import 'dart:collection';
 import 'dart:convert';
 import 'dart:io';
 import 'dart:typed_data';
@@ skipping 875 matching lines @@
 }
 
 abstract class CppSide {
   static const String serviceName = null;
   void startTest();
   void testFinished();
   void pingResponse();
   void echoResponse(EchoArgsList list);
 }
 
-
-class _CppSideProxyControl extends bindings.ProxyMessageHandler
-                                      implements bindings.ProxyControl {
+class _CppSideProxyControl
+    extends bindings.ProxyMessageHandler
+    implements bindings.ProxyControl {
   _CppSideProxyControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
 
   _CppSideProxyControl.fromHandle(
       core.MojoHandle handle) : super.fromHandle(handle);
 
   _CppSideProxyControl.unbound() : super.unbound();
 
   service_describer.ServiceDescription get serviceDescription =>
       new _CppSideServiceDescription();
 
   String get serviceName => CppSide.serviceName;
 
-  @override
   void handleResponse(bindings.ServiceMessage message) {
     switch (message.header.type) {
       default:
         proxyError("Unexpected message type: ${message.header.type}");
         close(immediate: true);
         break;
     }
   }
 
   @override
   String toString() {
     var superString = super.toString();
     return "_CppSideProxyControl($superString)";
   }
 }
 
-
-class CppSideProxy extends bindings.Proxy
-                              implements CppSide {
+class CppSideProxy
+    extends bindings.Proxy
+    implements CppSide {
   CppSideProxy.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint)
       : super(new _CppSideProxyControl.fromEndpoint(endpoint));
 
   CppSideProxy.fromHandle(core.MojoHandle handle)
       : super(new _CppSideProxyControl.fromHandle(handle));
 
   CppSideProxy.unbound()
       : super(new _CppSideProxyControl.unbound());
 
@@ skipping 43 matching lines @@
       ctrl.proxyError("The Proxy is closed.");
       return;
     }
     var params = new _CppSideEchoResponseParams();
     params.list = list;
     ctrl.sendMessage(params,
         _cppSideMethodEchoResponseName);
   }
 }
 
-
-class CppSideStub extends bindings.Stub {
+class _CppSideStubControl
+    extends bindings.StubMessageHandler
+    implements bindings.StubControl<CppSide> {
   CppSide _impl;
 
-  CppSideStub.fromEndpoint(
+  _CppSideStubControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint, [CppSide impl])
       : super.fromEndpoint(endpoint, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  CppSideStub.fromHandle(
+  _CppSideStubControl.fromHandle(
       core.MojoHandle handle, [CppSide impl])
       : super.fromHandle(handle, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  CppSideStub.unbound([this._impl]) : super.unbound();
-
-  static CppSideStub newFromEndpoint(
-      core.MojoMessagePipeEndpoint endpoint) {
-    assert(endpoint.setDescription("For CppSideStub"));
-    return new CppSideStub.fromEndpoint(endpoint);
-  }
+  _CppSideStubControl.unbound([this._impl]) : super.unbound();
 
 
 
   dynamic handleMessage(bindings.ServiceMessage message) {
     if (bindings.ControlMessageHandler.isControlMessage(message)) {
       return bindings.ControlMessageHandler.handleMessage(this,
                                                           0,
                                                           message);
     }
     if (_impl == null) {
@@ skipping 33 matching lines @@
   }
 
   @override
   void bind(core.MojoMessagePipeEndpoint endpoint) {
     super.bind(endpoint);
     if (!isOpen && (_impl != null)) {
       beginHandlingEvents();
     }
   }
 
+  @override
   String toString() {
     var superString = super.toString();
-    return "CppSideStub($superString)";
+    return "_CppSideStubControl($superString)";
   }
 
   int get version => 0;
 
   static service_describer.ServiceDescription _cachedServiceDescription;
   static service_describer.ServiceDescription get serviceDescription {
     if (_cachedServiceDescription == null) {
       _cachedServiceDescription = new _CppSideServiceDescription();
     }
     return _cachedServiceDescription;
   }
 }
 
+class CppSideStub
+    extends bindings.Stub<CppSide>
+    implements CppSide {
+  CppSideStub.fromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint, [CppSide impl])
+      : super(new _CppSideStubControl.fromEndpoint(endpoint, impl));
+
+  CppSideStub.fromHandle(
+      core.MojoHandle handle, [CppSide impl])
+      : super(new _CppSideStubControl.fromHandle(handle, impl));
+
+  CppSideStub.unbound([CppSide impl])
+      : super(new _CppSideStubControl.unbound(impl));
+
+  static CppSideStub newFromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint) {
+    assert(endpoint.setDescription("For CppSideStub"));
+    return new CppSideStub.fromEndpoint(endpoint);
+  }
+
+  static service_describer.ServiceDescription get serviceDescription =>
+      _CppSideStubControl.serviceDescription;
+
+
+  void startTest() {
+    return impl.startTest();
+  }
+  void testFinished() {
+    return impl.testFinished();
+  }
+  void pingResponse() {
+    return impl.pingResponse();
+  }
+  void echoResponse(EchoArgsList list) {
+    return impl.echoResponse(list);
+  }
+}
+
 const int _dartSideMethodSetClientName = 0;
 const int _dartSideMethodPingName = 1;
 const int _dartSideMethodEchoName = 2;
 
 class _DartSideServiceDescription 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 DartSide {
   static const String serviceName = null;
   void setClient(Object cppSide);
   void ping();
   void echo(int numIterations, EchoArgs arg);
 }
 
-
-class _DartSideProxyControl extends bindings.ProxyMessageHandler
-                                      implements bindings.ProxyControl {
+class _DartSideProxyControl
+    extends bindings.ProxyMessageHandler
+    implements bindings.ProxyControl {
   _DartSideProxyControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
 
   _DartSideProxyControl.fromHandle(
       core.MojoHandle handle) : super.fromHandle(handle);
 
   _DartSideProxyControl.unbound() : super.unbound();
 
   service_describer.ServiceDescription get serviceDescription =>
       new _DartSideServiceDescription();
 
   String get serviceName => DartSide.serviceName;
 
-  @override
   void handleResponse(bindings.ServiceMessage message) {
     switch (message.header.type) {
       default:
         proxyError("Unexpected message type: ${message.header.type}");
         close(immediate: true);
         break;
     }
   }
 
   @override
   String toString() {
     var superString = super.toString();
     return "_DartSideProxyControl($superString)";
   }
 }
 
-
-class DartSideProxy extends bindings.Proxy
-                              implements DartSide {
+class DartSideProxy
+    extends bindings.Proxy
+    implements DartSide {
   DartSideProxy.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint)
       : super(new _DartSideProxyControl.fromEndpoint(endpoint));
 
   DartSideProxy.fromHandle(core.MojoHandle handle)
       : super(new _DartSideProxyControl.fromHandle(handle));
 
   DartSideProxy.unbound()
       : super(new _DartSideProxyControl.unbound());
 
@@ skipping 36 matching lines @@
       return;
     }
     var params = new _DartSideEchoParams();
     params.numIterations = numIterations;
     params.arg = arg;
     ctrl.sendMessage(params,
         _dartSideMethodEchoName);
   }
 }
 
-
-class DartSideStub extends bindings.Stub {
+class _DartSideStubControl
+    extends bindings.StubMessageHandler
+    implements bindings.StubControl<DartSide> {
   DartSide _impl;
 
-  DartSideStub.fromEndpoint(
+  _DartSideStubControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint, [DartSide impl])
       : super.fromEndpoint(endpoint, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  DartSideStub.fromHandle(
+  _DartSideStubControl.fromHandle(
       core.MojoHandle handle, [DartSide impl])
       : super.fromHandle(handle, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  DartSideStub.unbound([this._impl]) : super.unbound();
-
-  static DartSideStub newFromEndpoint(
-      core.MojoMessagePipeEndpoint endpoint) {
-    assert(endpoint.setDescription("For DartSideStub"));
-    return new DartSideStub.fromEndpoint(endpoint);
-  }
+  _DartSideStubControl.unbound([this._impl]) : super.unbound();
 
 
 
   dynamic handleMessage(bindings.ServiceMessage message) {
     if (bindings.ControlMessageHandler.isControlMessage(message)) {
       return bindings.ControlMessageHandler.handleMessage(this,
                                                           0,
                                                           message);
     }
     if (_impl == null) {
@@ skipping 32 matching lines @@
   }
 
   @override
   void bind(core.MojoMessagePipeEndpoint endpoint) {
     super.bind(endpoint);
     if (!isOpen && (_impl != null)) {
       beginHandlingEvents();
     }
   }
 
+  @override
   String toString() {
     var superString = super.toString();
-    return "DartSideStub($superString)";
+    return "_DartSideStubControl($superString)";
   }
 
   int get version => 0;
 
   static service_describer.ServiceDescription _cachedServiceDescription;
   static service_describer.ServiceDescription get serviceDescription {
     if (_cachedServiceDescription == null) {
       _cachedServiceDescription = new _DartSideServiceDescription();
     }
     return _cachedServiceDescription;
   }
 }
 
+class DartSideStub
+    extends bindings.Stub<DartSide>
+    implements DartSide {
+  DartSideStub.fromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint, [DartSide impl])
+      : super(new _DartSideStubControl.fromEndpoint(endpoint, impl));
+
+  DartSideStub.fromHandle(
+      core.MojoHandle handle, [DartSide impl])
+      : super(new _DartSideStubControl.fromHandle(handle, impl));
+
+  DartSideStub.unbound([DartSide impl])
+      : super(new _DartSideStubControl.unbound(impl));
+
+  static DartSideStub newFromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint) {
+    assert(endpoint.setDescription("For DartSideStub"));
+    return new DartSideStub.fromEndpoint(endpoint);
+  }
+
+  static service_describer.ServiceDescription get serviceDescription =>
+      _DartSideStubControl.serviceDescription;
+
+
+  void setClient(Object cppSide) {
+    return impl.setClient(cppSide);
+  }
+  void ping() {
+    return impl.ping();
+  }
+  void echo(int numIterations, EchoArgs arg) {
+    return impl.echo(numIterations, arg);
+  }
+}
+
 
 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/9yaPWzbRhTHSUqyJVmy5a9EbdNUBRLULWrT+UAgdFKRunDRDEYTFPGkMNJFYiGRKkkVaaeMHTtmzNgxY8eOGTtmTLeMWQJkc++qR/l8vjudCIU6iMDD6cxLeO/H/717d8eqMboqUO5Dyf49LvNMybZ7CeUOtiy2GtQbUD6A8gmUV7Bdwnbv+Oig+f3B8VdtJ4iakd9sDQZ7tweDu24bkXZXsX0savcN/g0Npe0OWl3/66AT4vufY/t0Urs7bhhBPw/BH+JnBlud8pvUX66c1k1szy6ere/snnIxKC7jyzxbbTC34/cSP/cErkODf61hW8YWI/wI/97EJsB77j0SjkVsDrZjbPYwDOye33J6dsf3Oz1kd/0+sn8LHLvv/+TbYdAa/SAPsIeeG0UojEIb9R+idhsFTVJFgU0/n7TvC3RUo/5OuNd/vJM7efU2Z/z7NmdiY/V1aI3KQXZUPl3i837DcCL/r4w3225fwHsdWwHb3Qg7eA+NdcP69Rk2K0WuNaYfb5hykt+xzuoCvz8A38d+7wbo56HY//hKy/+8cXYcsnHLYNpN0sv/GlThhtuZEr1sYSuR+IO7/63ruWEXtXm8vlgwvVwC32m/acksml5IvFLlZino5cj1Oj+gcOB7IeLx2l1QvdB+L7JezCn0klHQC0llZHrZ00QvA2u2eqH91kkvrE4aTF5H7hMBvDPULhVetO7YqwR5VM/l89kDpmnrwxDkg7Su6RR92nxeNl5N6rlp5esV6Eu8lIl1LFjmnHtP1zTJ17dgPRQjsqj7GerfPYdGL3KK8+iUep+Yp6Pods9FnihPva5JXHxgzThPj/3WLE/XLS7G6+cWrJF5+tjSIC5WBet91X2VpHHwtSAcqnA3FeYjku/xdHljzuPyNVOqjkuVvH6R8lpWH9YUvCwFfZApncfppib6eJyZrT6Ivzrpowqcx/O/KY7bBsTuWcZtEa9tbGVs3rD/He6/E7l4BSDQSTlFXtPOZ/kEXGRxdQXyLyfoGKJxc1Wj+SzOh+PUXXVfXxavLKrOjtt4Aru/Pdt8Pu4aL5+nun3ufRRgPk/rfTzFtoHtj7gOPJ5B4P4T4tlz2F//Cwb037DP/mJ5VP4D4F8VII8tUoGb+FcG/qvAdQ3278Hx39fheRvyeLKU8vo4dG/d5L2nIrznecYRWXyddRw55XHjOo/HiiY8spL+T8vDUuJx7RaPR0kTHhlB/1cT8MgozDOhW+fOM+WU45qIR1ESt6flkVXQx1AQP1Yh1s+bR0HQ/2oCHjklHvz4saYJj7xkf3laHktKPPjxo6IJj2XJPsm0PJYV4sdQED/WNYmnlqD/tQQ88gr7lY96vhM1f3F6gv26Dc25XEnApaDMxfUeCbhsas5lJwGXojIXz/EEXLY04WIK/NhPwGVFwmUD5vy2P3zYQ6cDieWyrUm8FXGpJ+BSUucyHkgslwuac2kk4FJW5zIeSCyXixpwMSX7SIcJuKwq5Cue0+eeQ1ZTPoesCM4faD6WRDhHCfisKXx3EUaB63WaThA4v/I4xedxae+3meADu08mWvfQHLMSjl8m4FiRcLwAa6M+CkOng5pdx2v30HmOHwLbeejNTMDpfgJO6xJOm5Azt53IGUPi6I18/3t5TpysCfuyJNZ2BfuyeeD4bsJ5SoPZlz1SOE+hPwmpwTNFn42wPC+nvI/Bnrc8MfX6fshDj7nnUp/A73nEuff5/dC8z3Ni7m6E+qLvcUoacE/rPOe/AAAA//9qGb5tyDIAAA==";
 
   // 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);
   return _runtimeTypeInfo;
 }