Move mojo and mojom from mojo/public/dart to mojo/dart/packages

mojo/public/dart/mojo/lib/src/stub.dart

Index: mojo/public/dart/mojo/lib/src/stub.dart
diff --git a/mojo/public/dart/mojo/lib/src/stub.dart b/mojo/public/dart/mojo/lib/src/stub.dart
deleted file mode 100644
index dce10388d67af4bda2dd89967035932d768378c6..0000000000000000000000000000000000000000
--- a/mojo/public/dart/mojo/lib/src/stub.dart
+++ /dev/null
@@ -1,134 +0,0 @@
-// 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.
-
-part of bindings;
-
-abstract class Stub extends core.MojoEventHandler {
-  int _outstandingResponseFutures = 0;
-  bool _isClosing = false;
-  Completer _closeCompleter;
-
-  Stub.fromEndpoint(core.MojoMessagePipeEndpoint endpoint)
-      : super.fromEndpoint(endpoint);
-
-  Stub.fromHandle(core.MojoHandle handle) : super.fromHandle(handle);
-
-  Stub.unbound() : super.unbound();
-
-  dynamic handleMessage(ServiceMessage message);
-
-  void handleRead() {
-    var result = endpoint.queryAndRead();
-    if ((result.data == null) || (result.dataLength == 0)) {
-      throw new MojoCodecError('Unexpected empty message or error: $result');
-    }
-
-    // Prepare the response.
-    var message;
-    var response;
-    try {
-      message = new ServiceMessage.fromMessage(new Message(result.data,
-          result.handles, result.dataLength, result.handlesLength));
-      response = _isClosing ? null : handleMessage(message);
-    } catch (e) {
-      if (result.handles != null) {
-        result.handles.forEach((h) => h.close());
-      }
-      rethrow;
-    }
-
-    // If there's a response, send it.
-    if (response != null) {
-      if (response is Future) {
-        _outstandingResponseFutures++;
-        response.then((response) {
-          _outstandingResponseFutures--;
-          return response;
-        }).then(_sendResponse);
-      } else {
-        _sendResponse(response);
-      }
-    } else if (_isClosing && (_outstandingResponseFutures == 0)) {
-      // We are closing, there is no response to send for this message, and
-      // there are no outstanding response futures. Do the close now.
-      super.close().then((_) {
-        if (_isClosing) {
-          _isClosing = false;
-          _closeCompleter.complete(null);
-          _closeCompleter = null;
-        }
-      });
-    }
-  }
-
-  void _sendResponse(Message response) {
-    if (isOpen) {
-      endpoint.write(
-          response.buffer, response.buffer.lengthInBytes, response.handles);
-      // FailedPrecondition is only used to indicate that the other end of
-      // the pipe has been closed. We can ignore the close here and wait for
-      // the PeerClosed signal on the event stream.
-      assert(endpoint.status.isOk || endpoint.status.isFailedPrecondition);
-      if (_isClosing && (_outstandingResponseFutures == 0)) {
-        // This was the final response future for which we needed to send
-        // a response. It is safe to close.
-        super.close().then((_) {
-          if (_isClosing) {
-            _isClosing = false;
-            _closeCompleter.complete(null);
-            _closeCompleter = null;
-          }
-        });
-      }
-    }
-  }
-
-  void handleWrite() {
-    throw 'Unexpected write signal in client.';
-  }
-
-  // NB: |immediate| should only be true when calling close() while handling an
-  // exception thrown from handleRead(), e.g. when we receive a malformed
-  // message, or when we have received the PEER_CLOSED event.
-  @override
-  Future close({bool immediate: false}) {
-    if (isOpen &&
-        !immediate &&
-        !isPeerClosed &&
-        (isInHandler || (_outstandingResponseFutures > 0))) {
-      // Either close() is being called from within handleRead() or
-      // handleWrite(), or close() is being called while there are outstanding
-      // response futures. Defer the actual close until all response futures
-      // have been resolved.
-      _isClosing = true;
-      _closeCompleter = new Completer();
-      return _closeCompleter.future;
-    } else {
-      return super.close(immediate: immediate).then((_) {
-        if (_isClosing) {
-          _isClosing = false;
-          _closeCompleter.complete(null);
-          _closeCompleter = null;
-        }
-      });
-    }
-  }
-
-  Message buildResponse(Struct response, int name) {
-    var header = new MessageHeader(name);
-    return response.serializeWithHeader(header);
-  }
-
-  Message buildResponseWithId(Struct response, int name, int id, int flags) {
-    var header = new MessageHeader.withRequestId(name, flags, id);
-    return response.serializeWithHeader(header);
-  }
-
-  String toString() {
-    var superString = super.toString();
-    return "Stub(${superString})";
-  }
-
-  int get version;
-}