| Index: mojo/dart/packages/mojo_services/lib/mojo/tcp_connected_socket.mojom.dart
|
| diff --git a/mojo/dart/packages/mojo_services/lib/mojo/tcp_connected_socket.mojom.dart b/mojo/dart/packages/mojo_services/lib/mojo/tcp_connected_socket.mojom.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..a13a3a5ccd072bc167deeae427accdbbd0b2d52e
|
| --- /dev/null
|
| +++ b/mojo/dart/packages/mojo_services/lib/mojo/tcp_connected_socket.mojom.dart
|
| @@ -0,0 +1,171 @@
|
| +// 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 tcp_connected_socket_mojom;
|
| +
|
| +import 'dart:async';
|
| +
|
| +import 'package:mojo/bindings.dart' as bindings;
|
| +import 'package:mojo/core.dart' as core;
|
| +
|
| +
|
| +
|
| +const String TcpConnectedSocketName =
|
| + 'mojo::TCPConnectedSocket';
|
| +
|
| +abstract class TcpConnectedSocket {
|
| +
|
| +}
|
| +
|
| +
|
| +class TcpConnectedSocketProxyImpl extends bindings.Proxy {
|
| + TcpConnectedSocketProxyImpl.fromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
|
| +
|
| + TcpConnectedSocketProxyImpl.fromHandle(core.MojoHandle handle) :
|
| + super.fromHandle(handle);
|
| +
|
| + TcpConnectedSocketProxyImpl.unbound() : super.unbound();
|
| +
|
| + static TcpConnectedSocketProxyImpl newFromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) {
|
| + assert(endpoint.setDescription("For TcpConnectedSocketProxyImpl"));
|
| + return new TcpConnectedSocketProxyImpl.fromEndpoint(endpoint);
|
| + }
|
| +
|
| + String get name => TcpConnectedSocketName;
|
| +
|
| + void handleResponse(bindings.ServiceMessage message) {
|
| + switch (message.header.type) {
|
| + default:
|
| + proxyError("Unexpected message type: ${message.header.type}");
|
| + close(immediate: true);
|
| + break;
|
| + }
|
| + }
|
| +
|
| + String toString() {
|
| + var superString = super.toString();
|
| + return "TcpConnectedSocketProxyImpl($superString)";
|
| + }
|
| +}
|
| +
|
| +
|
| +class _TcpConnectedSocketProxyCalls implements TcpConnectedSocket {
|
| + TcpConnectedSocketProxyImpl _proxyImpl;
|
| +
|
| + _TcpConnectedSocketProxyCalls(this._proxyImpl);
|
| +}
|
| +
|
| +
|
| +class TcpConnectedSocketProxy implements bindings.ProxyBase {
|
| + final bindings.Proxy impl;
|
| + TcpConnectedSocket ptr;
|
| + final String name = TcpConnectedSocketName;
|
| +
|
| + TcpConnectedSocketProxy(TcpConnectedSocketProxyImpl proxyImpl) :
|
| + impl = proxyImpl,
|
| + ptr = new _TcpConnectedSocketProxyCalls(proxyImpl);
|
| +
|
| + TcpConnectedSocketProxy.fromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) :
|
| + impl = new TcpConnectedSocketProxyImpl.fromEndpoint(endpoint) {
|
| + ptr = new _TcpConnectedSocketProxyCalls(impl);
|
| + }
|
| +
|
| + TcpConnectedSocketProxy.fromHandle(core.MojoHandle handle) :
|
| + impl = new TcpConnectedSocketProxyImpl.fromHandle(handle) {
|
| + ptr = new _TcpConnectedSocketProxyCalls(impl);
|
| + }
|
| +
|
| + TcpConnectedSocketProxy.unbound() :
|
| + impl = new TcpConnectedSocketProxyImpl.unbound() {
|
| + ptr = new _TcpConnectedSocketProxyCalls(impl);
|
| + }
|
| +
|
| + factory TcpConnectedSocketProxy.connectToService(
|
| + bindings.ServiceConnector s, String url) {
|
| + TcpConnectedSocketProxy p = new TcpConnectedSocketProxy.unbound();
|
| + s.connectToService(url, p);
|
| + return p;
|
| + }
|
| +
|
| + static TcpConnectedSocketProxy newFromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) {
|
| + assert(endpoint.setDescription("For TcpConnectedSocketProxy"));
|
| + return new TcpConnectedSocketProxy.fromEndpoint(endpoint);
|
| + }
|
| +
|
| + Future close({bool immediate: false}) => impl.close(immediate: immediate);
|
| +
|
| + Future responseOrError(Future f) => impl.responseOrError(f);
|
| +
|
| + Future get errorFuture => impl.errorFuture;
|
| +
|
| + int get version => impl.version;
|
| +
|
| + Future<int> queryVersion() => impl.queryVersion();
|
| +
|
| + void requireVersion(int requiredVersion) {
|
| + impl.requireVersion(requiredVersion);
|
| + }
|
| +
|
| + String toString() {
|
| + return "TcpConnectedSocketProxy($impl)";
|
| + }
|
| +}
|
| +
|
| +
|
| +class TcpConnectedSocketStub extends bindings.Stub {
|
| + TcpConnectedSocket _impl = null;
|
| +
|
| + TcpConnectedSocketStub.fromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint, [this._impl])
|
| + : super.fromEndpoint(endpoint);
|
| +
|
| + TcpConnectedSocketStub.fromHandle(core.MojoHandle handle, [this._impl])
|
| + : super.fromHandle(handle);
|
| +
|
| + TcpConnectedSocketStub.unbound() : super.unbound();
|
| +
|
| + static TcpConnectedSocketStub newFromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) {
|
| + assert(endpoint.setDescription("For TcpConnectedSocketStub"));
|
| + return new TcpConnectedSocketStub.fromEndpoint(endpoint);
|
| + }
|
| +
|
| + static const String name = TcpConnectedSocketName;
|
| +
|
| +
|
| +
|
| + dynamic handleMessage(bindings.ServiceMessage message) {
|
| + if (bindings.ControlMessageHandler.isControlMessage(message)) {
|
| + return bindings.ControlMessageHandler.handleMessage(this,
|
| + 0,
|
| + message);
|
| + }
|
| + assert(_impl != null);
|
| + switch (message.header.type) {
|
| + default:
|
| + throw new bindings.MojoCodecError("Unexpected message name");
|
| + break;
|
| + }
|
| + return null;
|
| + }
|
| +
|
| + TcpConnectedSocket get impl => _impl;
|
| + set impl(TcpConnectedSocket d) {
|
| + assert(_impl == null);
|
| + _impl = d;
|
| + }
|
| +
|
| + String toString() {
|
| + var superString = super.toString();
|
| + return "TcpConnectedSocketStub($superString)";
|
| + }
|
| +
|
| + int get version => 0;
|
| +}
|
| +
|
| +
|
|
|