Dart: Futures -> Callbacks.

mojo/dart/packages/mojo/lib/src/control_message.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.
 
 part of bindings;
 
 // Handles InterfaceControlMessages for a stub.
 class ControlMessageHandler {
   static bool isControlMessage(ServiceMessage message) =>
       _isRun(message) || _isRunOrClose(message);
 
   static bool _isRun(ServiceMessage message) =>
       (message.header.type == icm.kRunMessageId);
 
   static bool _isRunOrClose(ServiceMessage message) =>
       (message.header.type == icm.kRunOrClosePipeMessageId);
 
-  static Future<Message> handleMessage(StubControl stubControl,
-                                       int interface_version,
-                                       ServiceMessage message) {
+  static handleMessage(
+      StubControl stubControl, int interface_version, ServiceMessage message) {
     assert(isControlMessage(message));
     if (_isRun(message)) {
-      return _handleRun(stubControl, interface_version, message);
+      _handleRun(stubControl, interface_version, message);
     } else {
       assert(_isRunOrClose(message));
-      return _handleRunOrClose(stubControl, interface_version, message);
+      _handleRunOrClose(stubControl, interface_version, message);
     }
   }
 
-  static Future<Message> _handleRun(StubControl stubControl,
-                                    int interface_version,
-                                    ServiceMessage message) {
+  static void _handleRun(
+      StubControl stubControl, int interface_version, ServiceMessage message) {
     // Construct RunMessage response.
     var response = new icm.RunResponseMessageParams();
     response.reserved0 = 16;
     response.reserved1 = 0;
     response.queryVersionResult = new icm.QueryVersionResult();
     response.queryVersionResult.version = interface_version;
     // Return response.
-    return new Future.value(
-        stubControl.buildResponseWithId(response,
-                                        icm.kRunMessageId,
-                                        message.header.requestId,
-                                        MessageHeader.kMessageIsResponse));
+    var responseMessage = stubControl.buildResponseWithId(
+        response,
+        icm.kRunMessageId,
+        message.header.requestId,
+        MessageHeader.kMessageIsResponse);
+    stubControl.sendResponse(responseMessage);
   }
 
-  static Future _handleRunOrClose(StubControl stubControl,
-                                  int interface_version,
-                                  ServiceMessage message) {
+  static void _handleRunOrClose(
+      StubControl stubControl, int interface_version, ServiceMessage message) {
     // Deserialize message.
     var params = icm.RunOrClosePipeMessageParams.deserialize(message.payload);
     // Grab required version.
     var requiredVersion = params.requireVersion.version;
     if (interface_version < requiredVersion) {
       // Stub does not implement required version. Close the pipe immediately.
       stubControl.close(immediate: true);
     }
-    return null;
   }
 }