Index: mojo/dart/packages/mojo_services/lib/mojo/tcp_bound_socket.mojom.dart |
diff --git a/mojo/dart/packages/mojo_services/lib/mojo/tcp_bound_socket.mojom.dart b/mojo/dart/packages/mojo_services/lib/mojo/tcp_bound_socket.mojom.dart |
index 4876b6f3c47b789aea1104560354dbb9885c2793..58dba99368e8753156ffced333eb45513bcf0c50 100644 |
--- a/mojo/dart/packages/mojo_services/lib/mojo/tcp_bound_socket.mojom.dart |
+++ b/mojo/dart/packages/mojo_services/lib/mojo/tcp_bound_socket.mojom.dart |
@@ -18,7 +18,7 @@ class _TcpBoundSocketStartListeningParams extends bindings.Struct { |
static const List<bindings.StructDataHeader> kVersions = const [ |
const bindings.StructDataHeader(16, 0) |
]; |
- Object server = null; |
+ tcp_server_socket_mojom.TcpServerSocketInterfaceRequest server = null; |
_TcpBoundSocketStartListeningParams() : super(kVersions.last.size); |
@@ -165,7 +165,7 @@ class _TcpBoundSocketConnectParams extends bindings.Struct { |
net_address_mojom.NetAddress remoteAddress = null; |
core.MojoDataPipeConsumer sendStream = null; |
core.MojoDataPipeProducer receiveStream = null; |
- Object clientSocket = null; |
+ tcp_connected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket = null; |
_TcpBoundSocketConnectParams() : super(kVersions.last.size); |
@@ -357,13 +357,51 @@ class _TcpBoundSocketServiceDescription implements service_describer.ServiceDesc |
abstract class TcpBoundSocket { |
static const String serviceName = null; |
- dynamic startListening(Object server,[Function responseFactory = null]); |
- dynamic connect(net_address_mojom.NetAddress remoteAddress,core.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,Object clientSocket,[Function responseFactory = null]); |
+ |
+ static service_describer.ServiceDescription _cachedServiceDescription; |
+ static service_describer.ServiceDescription get serviceDescription { |
+ if (_cachedServiceDescription == null) { |
+ _cachedServiceDescription = new _TcpBoundSocketServiceDescription(); |
+ } |
+ return _cachedServiceDescription; |
+ } |
+ |
+ static TcpBoundSocketProxy connectToService( |
+ bindings.ServiceConnector s, String url, [String serviceName]) { |
+ TcpBoundSocketProxy p = new TcpBoundSocketProxy.unbound(); |
+ String name = serviceName ?? TcpBoundSocket.serviceName; |
+ if ((name == null) || name.isEmpty) { |
+ throw new core.MojoApiError( |
+ "If an interface has no ServiceName, then one must be provided."); |
+ } |
+ s.connectToService(url, p, name); |
+ return p; |
+ } |
+ dynamic startListening(tcp_server_socket_mojom.TcpServerSocketInterfaceRequest server,[Function responseFactory = null]); |
+ dynamic connect(net_address_mojom.NetAddress remoteAddress,core.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,tcp_connected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket,[Function responseFactory = null]); |
+} |
+ |
+abstract class TcpBoundSocketInterface |
+ implements bindings.MojoInterface<TcpBoundSocket>, |
+ TcpBoundSocket { |
+ factory TcpBoundSocketInterface([TcpBoundSocket impl]) => |
+ new TcpBoundSocketStub.unbound(impl); |
+ factory TcpBoundSocketInterface.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint, |
+ [TcpBoundSocket impl]) => |
+ new TcpBoundSocketStub.fromEndpoint(endpoint, impl); |
+} |
+ |
+abstract class TcpBoundSocketInterfaceRequest |
+ implements bindings.MojoInterface<TcpBoundSocket>, |
+ TcpBoundSocket { |
+ factory TcpBoundSocketInterfaceRequest() => |
+ new TcpBoundSocketProxy.unbound(); |
} |
class _TcpBoundSocketProxyControl |
extends bindings.ProxyMessageHandler |
- implements bindings.ProxyControl { |
+ implements bindings.ProxyControl<TcpBoundSocket> { |
_TcpBoundSocketProxyControl.fromEndpoint( |
core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); |
@@ -372,9 +410,6 @@ class _TcpBoundSocketProxyControl |
_TcpBoundSocketProxyControl.unbound() : super.unbound(); |
- service_describer.ServiceDescription get serviceDescription => |
- new _TcpBoundSocketServiceDescription(); |
- |
String get serviceName => TcpBoundSocket.serviceName; |
void handleResponse(bindings.ServiceMessage message) { |
@@ -426,6 +461,11 @@ class _TcpBoundSocketProxyControl |
} |
} |
+ TcpBoundSocket get impl => null; |
+ set impl(TcpBoundSocket _) { |
+ throw new core.MojoApiError("The impl of a Proxy cannot be set."); |
+ } |
+ |
@override |
String toString() { |
var superString = super.toString(); |
@@ -434,8 +474,10 @@ class _TcpBoundSocketProxyControl |
} |
class TcpBoundSocketProxy |
- extends bindings.Proxy |
- implements TcpBoundSocket { |
+ extends bindings.Proxy<TcpBoundSocket> |
+ implements TcpBoundSocket, |
+ TcpBoundSocketInterface, |
+ TcpBoundSocketInterfaceRequest { |
TcpBoundSocketProxy.fromEndpoint( |
core.MojoMessagePipeEndpoint endpoint) |
: super(new _TcpBoundSocketProxyControl.fromEndpoint(endpoint)); |
@@ -452,15 +494,8 @@ class TcpBoundSocketProxy |
return new TcpBoundSocketProxy.fromEndpoint(endpoint); |
} |
- factory TcpBoundSocketProxy.connectToService( |
- bindings.ServiceConnector s, String url, [String serviceName]) { |
- TcpBoundSocketProxy p = new TcpBoundSocketProxy.unbound(); |
- s.connectToService(url, p, serviceName); |
- return p; |
- } |
- |
- dynamic startListening(Object server,[Function responseFactory = null]) { |
+ dynamic startListening(tcp_server_socket_mojom.TcpServerSocketInterfaceRequest server,[Function responseFactory = null]) { |
var params = new _TcpBoundSocketStartListeningParams(); |
params.server = server; |
return ctrl.sendMessageWithRequestId( |
@@ -469,7 +504,7 @@ class TcpBoundSocketProxy |
-1, |
bindings.MessageHeader.kMessageExpectsResponse); |
} |
- dynamic connect(net_address_mojom.NetAddress remoteAddress,core.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,Object clientSocket,[Function responseFactory = null]) { |
+ dynamic connect(net_address_mojom.NetAddress remoteAddress,core.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,tcp_connected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket,[Function responseFactory = null]) { |
var params = new _TcpBoundSocketConnectParams(); |
params.remoteAddress = remoteAddress; |
params.sendStream = sendStream; |
@@ -502,6 +537,8 @@ class _TcpBoundSocketStubControl |
_TcpBoundSocketStubControl.unbound([this._impl]) : super.unbound(); |
+ String get serviceName => TcpBoundSocket.serviceName; |
+ |
TcpBoundSocketStartListeningResponseParams _tcpBoundSocketStartListeningResponseParamsFactory(network_error_mojom.NetworkError result) { |
var result = new TcpBoundSocketStartListeningResponseParams(); |
@@ -601,19 +638,16 @@ class _TcpBoundSocketStubControl |
} |
int get version => 0; |
- |
- static service_describer.ServiceDescription _cachedServiceDescription; |
- static service_describer.ServiceDescription get serviceDescription { |
- if (_cachedServiceDescription == null) { |
- _cachedServiceDescription = new _TcpBoundSocketServiceDescription(); |
- } |
- return _cachedServiceDescription; |
- } |
} |
class TcpBoundSocketStub |
extends bindings.Stub<TcpBoundSocket> |
- implements TcpBoundSocket { |
+ implements TcpBoundSocket, |
+ TcpBoundSocketInterface, |
+ TcpBoundSocketInterfaceRequest { |
+ TcpBoundSocketStub.unbound([TcpBoundSocket impl]) |
+ : super(new _TcpBoundSocketStubControl.unbound(impl)); |
+ |
TcpBoundSocketStub.fromEndpoint( |
core.MojoMessagePipeEndpoint endpoint, [TcpBoundSocket impl]) |
: super(new _TcpBoundSocketStubControl.fromEndpoint(endpoint, impl)); |
@@ -622,23 +656,17 @@ class TcpBoundSocketStub |
core.MojoHandle handle, [TcpBoundSocket impl]) |
: super(new _TcpBoundSocketStubControl.fromHandle(handle, impl)); |
- TcpBoundSocketStub.unbound([TcpBoundSocket impl]) |
- : super(new _TcpBoundSocketStubControl.unbound(impl)); |
- |
static TcpBoundSocketStub newFromEndpoint( |
core.MojoMessagePipeEndpoint endpoint) { |
assert(endpoint.setDescription("For TcpBoundSocketStub")); |
return new TcpBoundSocketStub.fromEndpoint(endpoint); |
} |
- static service_describer.ServiceDescription get serviceDescription => |
- _TcpBoundSocketStubControl.serviceDescription; |
- |
- dynamic startListening(Object server,[Function responseFactory = null]) { |
+ dynamic startListening(tcp_server_socket_mojom.TcpServerSocketInterfaceRequest server,[Function responseFactory = null]) { |
return impl.startListening(server,responseFactory); |
} |
- dynamic connect(net_address_mojom.NetAddress remoteAddress,core.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,Object clientSocket,[Function responseFactory = null]) { |
+ dynamic connect(net_address_mojom.NetAddress remoteAddress,core.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,tcp_connected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket,[Function responseFactory = null]) { |
return impl.connect(remoteAddress,sendStream,receiveStream,clientSocket,responseFactory); |
} |
} |