Dart: Refactor Stubs

mojo/dart/packages/_mojo_for_test_only/lib/sample/sample_factory.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 sample_factory_mojom;
 import 'dart:async';
 import 'dart:collection';
 import 'dart:convert';
 import 'dart:io';
 import 'dart:typed_data';
@@ skipping 1084 matching lines @@
   dynamic getAllTypeDefinitions([Function responseFactory]) =>
     responseFactory(getAllMojomTypeDefinitions());
 }
 
 abstract class NamedObject {
   static const String serviceName = "sample::NamedObject";
   void setName(String name);
   dynamic getName([Function responseFactory = null]);
 }
 
-
-class _NamedObjectProxyControl extends bindings.ProxyMessageHandler
-                                      implements bindings.ProxyControl {
+class _NamedObjectProxyControl
+    extends bindings.ProxyMessageHandler
+    implements bindings.ProxyControl {
   _NamedObjectProxyControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
 
   _NamedObjectProxyControl.fromHandle(
       core.MojoHandle handle) : super.fromHandle(handle);
 
   _NamedObjectProxyControl.unbound() : super.unbound();
 
   service_describer.ServiceDescription get serviceDescription =>
       new _NamedObjectServiceDescription();
 
   String get serviceName => NamedObject.serviceName;
 
-  @override
   void handleResponse(bindings.ServiceMessage message) {
     switch (message.header.type) {
       case _namedObjectMethodGetNameName:
         var r = NamedObjectGetNameResponseParams.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 "_NamedObjectProxyControl($superString)";
   }
 }
 
-
-class NamedObjectProxy extends bindings.Proxy
-                              implements NamedObject {
+class NamedObjectProxy
+    extends bindings.Proxy
+    implements NamedObject {
   NamedObjectProxy.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint)
       : super(new _NamedObjectProxyControl.fromEndpoint(endpoint));
 
   NamedObjectProxy.fromHandle(core.MojoHandle handle)
       : super(new _NamedObjectProxyControl.fromHandle(handle));
 
   NamedObjectProxy.unbound()
       : super(new _NamedObjectProxyControl.unbound());
 
@@ skipping 24 matching lines @@
   dynamic getName([Function responseFactory = null]) {
     var params = new _NamedObjectGetNameParams();
     return ctrl.sendMessageWithRequestId(
         params,
         _namedObjectMethodGetNameName,
         -1,
         bindings.MessageHeader.kMessageExpectsResponse);
   }
 }
 
-
-class NamedObjectStub extends bindings.Stub {
+class _NamedObjectStubControl
+    extends bindings.StubMessageHandler
+    implements bindings.StubControl<NamedObject> {
   NamedObject _impl;
 
-  NamedObjectStub.fromEndpoint(
+  _NamedObjectStubControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint, [NamedObject impl])
       : super.fromEndpoint(endpoint, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  NamedObjectStub.fromHandle(
+  _NamedObjectStubControl.fromHandle(
       core.MojoHandle handle, [NamedObject impl])
       : super.fromHandle(handle, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  NamedObjectStub.unbound([this._impl]) : super.unbound();
-
-  static NamedObjectStub newFromEndpoint(
-      core.MojoMessagePipeEndpoint endpoint) {
-    assert(endpoint.setDescription("For NamedObjectStub"));
-    return new NamedObjectStub.fromEndpoint(endpoint);
-  }
+  _NamedObjectStubControl.unbound([this._impl]) : super.unbound();
 
 
   NamedObjectGetNameResponseParams _namedObjectGetNameResponseParamsFactory(String name) {
     var result = new NamedObjectGetNameResponseParams();
     result.name = name;
     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 "NamedObjectStub($superString)";
+    return "_NamedObjectStubControl($superString)";
   }
 
   int get version => 0;
 
   static service_describer.ServiceDescription _cachedServiceDescription;
   static service_describer.ServiceDescription get serviceDescription {
     if (_cachedServiceDescription == null) {
       _cachedServiceDescription = new _NamedObjectServiceDescription();
     }
     return _cachedServiceDescription;
   }
 }
 
+class NamedObjectStub
+    extends bindings.Stub<NamedObject>
+    implements NamedObject {
+  NamedObjectStub.fromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint, [NamedObject impl])
+      : super(new _NamedObjectStubControl.fromEndpoint(endpoint, impl));
+
+  NamedObjectStub.fromHandle(
+      core.MojoHandle handle, [NamedObject impl])
+      : super(new _NamedObjectStubControl.fromHandle(handle, impl));
+
+  NamedObjectStub.unbound([NamedObject impl])
+      : super(new _NamedObjectStubControl.unbound(impl));
+
+  static NamedObjectStub newFromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint) {
+    assert(endpoint.setDescription("For NamedObjectStub"));
+    return new NamedObjectStub.fromEndpoint(endpoint);
+  }
+
+  static service_describer.ServiceDescription get serviceDescription =>
+      _NamedObjectStubControl.serviceDescription;
+
+
+  void setName(String name) {
+    return impl.setName(name);
+  }
+  dynamic getName([Function responseFactory = null]) {
+    return impl.getName(responseFactory);
+  }
+}
+
 const int _factoryMethodDoStuffName = 0;
 const int _factoryMethodDoStuff2Name = 1;
 const int _factoryMethodCreateNamedObjectName = 2;
 const int _factoryMethodRequestImportedInterfaceName = 3;
 const int _factoryMethodTakeImportedInterfaceName = 4;
 
 class _FactoryServiceDescription 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 Factory {
   static const String serviceName = null;
   dynamic doStuff(Request request,core.MojoMessagePipeEndpoint pipe,[Function responseFactory = null]);
   dynamic doStuff2(core.MojoDataPipeConsumer pipe,[Function responseFactory = null]);
   void createNamedObject(Object obj);
   dynamic requestImportedInterface(Object obj,[Function responseFactory = null]);
   dynamic takeImportedInterface(Object obj,[Function responseFactory = null]);
 }
 
-
-class _FactoryProxyControl extends bindings.ProxyMessageHandler
-                                      implements bindings.ProxyControl {
+class _FactoryProxyControl
+    extends bindings.ProxyMessageHandler
+    implements bindings.ProxyControl {
   _FactoryProxyControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
 
   _FactoryProxyControl.fromHandle(
       core.MojoHandle handle) : super.fromHandle(handle);
 
   _FactoryProxyControl.unbound() : super.unbound();
 
   service_describer.ServiceDescription get serviceDescription =>
       new _FactoryServiceDescription();
 
   String get serviceName => Factory.serviceName;
 
-  @override
   void handleResponse(bindings.ServiceMessage message) {
     switch (message.header.type) {
       case _factoryMethodDoStuffName:
         var r = FactoryDoStuffResponseParams.deserialize(
             message.payload);
         if (!message.header.hasRequestId) {
           proxyError("Expected a message with a valid request Id.");
           return;
         }
         Completer c = completerMap[message.header.requestId];
@@ skipping 76 matching lines @@
     }
   }
 
   @override
   String toString() {
     var superString = super.toString();
     return "_FactoryProxyControl($superString)";
   }
 }
 
-
-class FactoryProxy extends bindings.Proxy
-                              implements Factory {
+class FactoryProxy
+    extends bindings.Proxy
+    implements Factory {
   FactoryProxy.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint)
       : super(new _FactoryProxyControl.fromEndpoint(endpoint));
 
   FactoryProxy.fromHandle(core.MojoHandle handle)
       : super(new _FactoryProxyControl.fromHandle(handle));
 
   FactoryProxy.unbound()
       : super(new _FactoryProxyControl.unbound());
 
@@ skipping 53 matching lines @@
     var params = new _FactoryTakeImportedInterfaceParams();
     params.obj = obj;
     return ctrl.sendMessageWithRequestId(
         params,
         _factoryMethodTakeImportedInterfaceName,
         -1,
         bindings.MessageHeader.kMessageExpectsResponse);
   }
 }
 
-
-class FactoryStub extends bindings.Stub {
+class _FactoryStubControl
+    extends bindings.StubMessageHandler
+    implements bindings.StubControl<Factory> {
   Factory _impl;
 
-  FactoryStub.fromEndpoint(
+  _FactoryStubControl.fromEndpoint(
       core.MojoMessagePipeEndpoint endpoint, [Factory impl])
       : super.fromEndpoint(endpoint, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  FactoryStub.fromHandle(
+  _FactoryStubControl.fromHandle(
       core.MojoHandle handle, [Factory impl])
       : super.fromHandle(handle, autoBegin: impl != null) {
     _impl = impl;
   }
 
-  FactoryStub.unbound([this._impl]) : super.unbound();
-
-  static FactoryStub newFromEndpoint(
-      core.MojoMessagePipeEndpoint endpoint) {
-    assert(endpoint.setDescription("For FactoryStub"));
-    return new FactoryStub.fromEndpoint(endpoint);
-  }
+  _FactoryStubControl.unbound([this._impl]) : super.unbound();
 
 
   FactoryDoStuffResponseParams _factoryDoStuffResponseParamsFactory(Response response, String text) {
     var result = new FactoryDoStuffResponseParams();
     result.response = response;
     result.text = text;
     return result;
   }
   FactoryDoStuff2ResponseParams _factoryDoStuff2ResponseParamsFactory(String text) {
     var result = new FactoryDoStuff2ResponseParams();
@@ skipping 133 matching lines @@
   }
 
   @override
   void bind(core.MojoMessagePipeEndpoint endpoint) {
     super.bind(endpoint);
     if (!isOpen && (_impl != null)) {
       beginHandlingEvents();
     }
   }
 
+  @override
   String toString() {
     var superString = super.toString();
-    return "FactoryStub($superString)";
+    return "_FactoryStubControl($superString)";
   }
 
   int get version => 0;
 
   static service_describer.ServiceDescription _cachedServiceDescription;
   static service_describer.ServiceDescription get serviceDescription {
     if (_cachedServiceDescription == null) {
       _cachedServiceDescription = new _FactoryServiceDescription();
     }
     return _cachedServiceDescription;
   }
 }
 
+class FactoryStub
+    extends bindings.Stub<Factory>
+    implements Factory {
+  FactoryStub.fromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint, [Factory impl])
+      : super(new _FactoryStubControl.fromEndpoint(endpoint, impl));
+
+  FactoryStub.fromHandle(
+      core.MojoHandle handle, [Factory impl])
+      : super(new _FactoryStubControl.fromHandle(handle, impl));
+
+  FactoryStub.unbound([Factory impl])
+      : super(new _FactoryStubControl.unbound(impl));
+
+  static FactoryStub newFromEndpoint(
+      core.MojoMessagePipeEndpoint endpoint) {
+    assert(endpoint.setDescription("For FactoryStub"));
+    return new FactoryStub.fromEndpoint(endpoint);
+  }
+
+  static service_describer.ServiceDescription get serviceDescription =>
+      _FactoryStubControl.serviceDescription;
+
+
+  dynamic doStuff(Request request,core.MojoMessagePipeEndpoint pipe,[Function responseFactory = null]) {
+    return impl.doStuff(request,pipe,responseFactory);
+  }
+  dynamic doStuff2(core.MojoDataPipeConsumer pipe,[Function responseFactory = null]) {
+    return impl.doStuff2(pipe,responseFactory);
+  }
+  void createNamedObject(Object obj) {
+    return impl.createNamedObject(obj);
+  }
+  dynamic requestImportedInterface(Object obj,[Function responseFactory = null]) {
+    return impl.requestImportedInterface(obj,responseFactory);
+  }
+  dynamic takeImportedInterface(Object obj,[Function responseFactory = null]) {
+    return impl.takeImportedInterface(obj,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/+xaT3PbRBTXH4eaf6nTDI0oberQNrgwRKYcyOTUGShNhhnIEA7kQkZ21omDbQlJZgwnjjlyzEfgI+Rj8DFy5MgNVtFbe73alSxHltYZ78zOWooU7fu93/uzu89QwlaB8RxG9v42da3iXobrD3Bfxd2zuk4H7ex8a3XR8XeNM9T0uc8/gXd+ONx/dfTNq8Od8MUt9j32+5cw1nAv4V5l5vUjjA6Mj3Ff43zna6vp2+5vE89D9H++R7/0kedfz8Pg/t1z7J6HdmG+gRw6g2NwfVEdx7X28fi1Ux/JrVByk/Yvc/2Sua4zOP0HjX2OtLu438Gd4HQf/14e6ncIX0Q/G7i/hXsL959wN/uea3bsptUxT2z7pIPMU7uLzN9dy+zaZ7bpuc3wh9NvdNpNs93zkduymsgzG+3ecbt34pk+Btgzwy8ftcIvbwUvdaPfJ/g8xH0Jfgf4aYBzicJjiXr+HIhZXQ7Hv1fC8dTg434F40VpMtwVCnf6/4lw/8o+8PutVkS+D0GWvPCtMn6AyD3QJ5c3aHWBvGsgM8j7qQv2xMpNWp680qjvn6rj8tL2u8SxP1HLih8inAJ+3CuAHwozD4OZL/GTSX6Uh28pBt/yFPiqMfi+A99z2g7ixZ8A389yxLdC+TCVE0cNau4adT1ruzVgLiO7DePcwm75rQI6E+H0BPInWeyWzJfkL0n5zUtBfpi33fpo4PPsNsD3aQF2qwjyZZHdivKMuj7yA1ngRfQL9vuCxeupJHlGRZuJv3pBEo2i/RXLi7TxL2s/lRT/Al5sFmRHWoIdqdQ8WT79Q65T8mlbgNP7uK+M8yl0hIJ1s4y8Ugvglcg/B7z6QlL/rHLWl1XBultLgZdG6UPEry9dZPmI3Y2I4vesYH9NcHBS2pdo/2EDMIjIP1whzo+d5Zlnvg37HHbjTMiTjQJ4ojHzIPdXYc4swyfdl7up3V5CXqWnwF+PsVuSJ8N6dq/r2K6PjvcIbKw+NiWx2/OM7LYGGIjkn6e8Sya73cw5Porstk7tgzzAvQ0K3opoOnzuE7DloR0nvDBtfkcWRn+m5PGuQB/PwU/G8Hju8j2Z+PxRzusI2fmcFJ9KKfRSiolPj3B/L5i/9TPizZh3nnKb4tMzwIArP5VbLuw5nT0H730uwf6lrPEpax4HvnM9hsckOC14nI7Hz8FHLHjMj0sDkmepfL0QvV7A+BfD58uY/Wh6PlVOXnWHs248QO6v7eb1BsFEdSii9eYDODcVLDMjPHmYc51DklxGzDmORumVPR/b1+PPHWZ1fn2A/GudsfN+dMvOHUh9A8grTX2DrPvDPTBkHi9W5nB/mPCprGV7fkfs6LXAjtYlsaMrJVs7ei2ZHZUn4IcSE9dmdc45wkmOuox58zfrwDnZ/Y1onWG8EY9T2jpQUp/F1IGS2xH83oX38sKPrQeukbofsKs/dDHvFGVUKzpr3r0J+hsI9g2XQed54Za23qCUc73dXbhXVL0dDx+NDuQZ1DVpnPuk3YN1Rtd20VEAksfnTTA+LiDeqyAD4U2ZE2fUKdb9lSlw1G+w7l8Fn18EfrKs+2n/KYor23o2cYWtLyT5HVNWGNHT/ZzjCrteNtT5iCNrizgS2Q8pMo4k1X+S5/8PAAD//wmWKGaINQAA";
 
   // 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);
   sample_import_mojom.getAllMojomTypeDefinitions()
       .forEach((String s, mojom_types.UserDefinedType udt) {
           _runtimeTypeInfo.typeMap[s] = udt;
       });
 
   return _runtimeTypeInfo;
 }