| 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
|
| index e6b460fa920892b9e240ff907825c2cfb90c7132..62d4854a331ee93c9fdc28164f760e8168a083f7 100644
|
| --- 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
|
| @@ -26,24 +26,22 @@ abstract class TcpConnectedSocket {
|
| }
|
|
|
|
|
| -class _TcpConnectedSocketProxyImpl extends bindings.Proxy {
|
| - _TcpConnectedSocketProxyImpl.fromEndpoint(
|
| +class _TcpConnectedSocketProxyControl extends bindings.ProxyMessageHandler
|
| + implements bindings.ProxyControl {
|
| + _TcpConnectedSocketProxyControl.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
|
|
|
| - _TcpConnectedSocketProxyImpl.fromHandle(core.MojoHandle handle) :
|
| - super.fromHandle(handle);
|
| + _TcpConnectedSocketProxyControl.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);
|
| - }
|
| + _TcpConnectedSocketProxyControl.unbound() : super.unbound();
|
|
|
| service_describer.ServiceDescription get serviceDescription =>
|
| - new _TcpConnectedSocketServiceDescription();
|
| + new _TcpConnectedSocketServiceDescription();
|
| +
|
| + String get serviceName => TcpConnectedSocket.serviceName;
|
|
|
| + @override
|
| void handleResponse(bindings.ServiceMessage message) {
|
| switch (message.header.type) {
|
| default:
|
| @@ -53,40 +51,30 @@ class _TcpConnectedSocketProxyImpl extends bindings.Proxy {
|
| }
|
| }
|
|
|
| + @override
|
| String toString() {
|
| var superString = super.toString();
|
| - return "_TcpConnectedSocketProxyImpl($superString)";
|
| + return "_TcpConnectedSocketProxyControl($superString)";
|
| }
|
| }
|
|
|
|
|
| -class _TcpConnectedSocketProxyCalls implements TcpConnectedSocket {
|
| - _TcpConnectedSocketProxyCalls(_TcpConnectedSocketProxyImpl _);
|
| -}
|
| -
|
| -
|
| -class TcpConnectedSocketProxy implements bindings.ProxyBase {
|
| - final bindings.Proxy impl;
|
| - TcpConnectedSocket ptr;
|
| -
|
| - TcpConnectedSocketProxy(_TcpConnectedSocketProxyImpl proxyImpl) :
|
| - impl = proxyImpl,
|
| - ptr = new _TcpConnectedSocketProxyCalls(proxyImpl);
|
| -
|
| +class TcpConnectedSocketProxy extends bindings.Proxy
|
| + implements TcpConnectedSocket {
|
| TcpConnectedSocketProxy.fromEndpoint(
|
| - core.MojoMessagePipeEndpoint endpoint) :
|
| - impl = new _TcpConnectedSocketProxyImpl.fromEndpoint(endpoint) {
|
| - ptr = new _TcpConnectedSocketProxyCalls(impl);
|
| - }
|
| + core.MojoMessagePipeEndpoint endpoint)
|
| + : super(new _TcpConnectedSocketProxyControl.fromEndpoint(endpoint));
|
|
|
| - TcpConnectedSocketProxy.fromHandle(core.MojoHandle handle) :
|
| - impl = new _TcpConnectedSocketProxyImpl.fromHandle(handle) {
|
| - ptr = new _TcpConnectedSocketProxyCalls(impl);
|
| - }
|
| + TcpConnectedSocketProxy.fromHandle(core.MojoHandle handle)
|
| + : super(new _TcpConnectedSocketProxyControl.fromHandle(handle));
|
|
|
| - TcpConnectedSocketProxy.unbound() :
|
| - impl = new _TcpConnectedSocketProxyImpl.unbound() {
|
| - ptr = new _TcpConnectedSocketProxyCalls(impl);
|
| + TcpConnectedSocketProxy.unbound()
|
| + : super(new _TcpConnectedSocketProxyControl.unbound());
|
| +
|
| + static TcpConnectedSocketProxy newFromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) {
|
| + assert(endpoint.setDescription("For TcpConnectedSocketProxy"));
|
| + return new TcpConnectedSocketProxy.fromEndpoint(endpoint);
|
| }
|
|
|
| factory TcpConnectedSocketProxy.connectToService(
|
| @@ -96,31 +84,7 @@ class TcpConnectedSocketProxy implements bindings.ProxyBase {
|
| return p;
|
| }
|
|
|
| - static TcpConnectedSocketProxy newFromEndpoint(
|
| - core.MojoMessagePipeEndpoint endpoint) {
|
| - assert(endpoint.setDescription("For TcpConnectedSocketProxy"));
|
| - return new TcpConnectedSocketProxy.fromEndpoint(endpoint);
|
| - }
|
| -
|
| - String get serviceName => TcpConnectedSocket.serviceName;
|
| -
|
| - 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)";
|
| - }
|
| }
|
|
|
|
|
|
|