Dart: Removes need to call listen().

services/dart/test/pingpong/main.dart

 // Copyright 2015 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 'mojo:application';
 import 'mojo:bindings';
 import 'mojo:core';
 
 import 'package:services/dart/test/pingpong_service.mojom.dart';
@@ skipping 14 matching lines @@
       stub.close();
     }
   }
 }
 
 class PingPongServiceImpl implements PingPongService {
   PingPongServiceStub _stub;
   Application _application;
   PingPongClientProxy _pingPongClient;
 
-  PingPongServiceImpl(Application application, MojoMessagePipeEndpoint endpoint)
-      : _application = application {
-    _stub = new PingPongServiceStub.fromEndpoint(endpoint, impl: this);
+  PingPongServiceImpl(this._application, MojoMessagePipeEndpoint endpoint) {
+    _stub = new PingPongServiceStub.fromEndpoint(endpoint, this);
   }
 
   PingPongServiceImpl.fromStub(this._stub) {
     _stub.impl = this;
   }
 
-  listen() => _stub.listen();
-
   void setClient(ProxyBase proxyBase) {
     assert(_pingPongClient == null);
     _pingPongClient = proxyBase;
   }
 
   void ping(int pingValue) {
     if (_pingPongClient != null) {
       _pingPongClient.ptr.pong(pingValue + 1);
     }
   }
 
   Future pingTargetUrl(String url, int count, Function responseFactory) async {
     if (_application == null) {
       return responseFactory(false);
     }
     var completer = new Completer();
     var pingPongService = new PingPongServiceProxy.unbound();
     _application.connectToService(url, pingPongService);
 
     var pingPongClient = new PingPongClientImpl.unbound(count, completer);
     pingPongService.ptr.setClient(pingPongClient.stub);
-    pingPongClient.stub.listen();
 
     for (var i = 0; i < count; i++) {
       pingPongService.ptr.ping(i);
     }
     await completer.future;
     pingPongService.ptr.quit();
     pingPongService.close();
 
     return responseFactory(true);
   }
 
-  Future pingTargetService(ProxyBase proxyBase, int count,
-      Function responseFactory) async {
+  Future pingTargetService(ProxyBase proxyBase,
+                           int count,
+                           Function responseFactory) async {
     var pingPongService = proxyBase;
     var completer = new Completer();
     var client = new PingPongClientImpl.unbound(count, completer);
     pingPongService.ptr.setClient(client.stub);
-    client.stub.listen();
 
     for (var i = 0; i < count; i++) {
       pingPongService.ptr.ping(i);
     }
     await completer.future;
     pingPongService.ptr.quit();
     pingPongService.close();
 
     return responseFactory(true);
   }
 
   getPingPongService(PingPongServiceStub serviceStub) {
-    new PingPongServiceImpl.fromStub(serviceStub)..listen();
+    new PingPongServiceImpl.fromStub(serviceStub);
   }
 
   void quit() {
     if (_pingPongClient != null) {
       _pingPongClient.close();
       _pingPongClient = null;
     }
     _stub.close();
     _stub = null;
   }
 }
 
 class PingPongApplication extends Application {
   PingPongApplication.fromHandle(MojoHandle handle) : super.fromHandle(handle);
 
   @override
   void acceptConnection(String requestorUrl, String resolvedUrl,
       ApplicationConnection connection) {
     connection.provideService(
         PingPongServiceName,
         (endpoint) => new PingPongServiceImpl(this, endpoint));
-    connection.listen();
   }
 }
 
 main(List args) {
   MojoHandle appHandle = new MojoHandle(args[0]);
   String url = args[1];
   new PingPongApplication.fromHandle(appHandle);
 }