| Index: mojo/dart/packages/mojo_services/lib/mojo/web_socket.mojom.dart
|
| diff --git a/mojo/dart/packages/mojo_services/lib/mojo/web_socket.mojom.dart b/mojo/dart/packages/mojo_services/lib/mojo/web_socket.mojom.dart
|
| index 61ca5dac920178d386a267cd5f33f850c8877478..581c7f0380f329f9655da6166c244bfe085a39a7 100644
|
| --- a/mojo/dart/packages/mojo_services/lib/mojo/web_socket.mojom.dart
|
| +++ b/mojo/dart/packages/mojo_services/lib/mojo/web_socket.mojom.dart
|
| @@ -938,9 +938,9 @@ abstract class WebSocket {
|
| static const int kAbnormalCloseCode = 1006;
|
| }
|
|
|
| -
|
| -class _WebSocketProxyControl extends bindings.ProxyMessageHandler
|
| - implements bindings.ProxyControl {
|
| +class _WebSocketProxyControl
|
| + extends bindings.ProxyMessageHandler
|
| + implements bindings.ProxyControl {
|
| _WebSocketProxyControl.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
|
|
|
| @@ -954,7 +954,6 @@ class _WebSocketProxyControl extends bindings.ProxyMessageHandler
|
|
|
| String get serviceName => WebSocket.serviceName;
|
|
|
| - @override
|
| void handleResponse(bindings.ServiceMessage message) {
|
| switch (message.header.type) {
|
| default:
|
| @@ -971,9 +970,9 @@ class _WebSocketProxyControl extends bindings.ProxyMessageHandler
|
| }
|
| }
|
|
|
| -
|
| -class WebSocketProxy extends bindings.Proxy
|
| - implements WebSocket {
|
| +class WebSocketProxy
|
| + extends bindings.Proxy
|
| + implements WebSocket {
|
| WebSocketProxy.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint)
|
| : super(new _WebSocketProxyControl.fromEndpoint(endpoint));
|
| @@ -1047,29 +1046,24 @@ class WebSocketProxy extends bindings.Proxy
|
| }
|
| }
|
|
|
| -
|
| -class WebSocketStub extends bindings.Stub {
|
| +class _WebSocketStubControl
|
| + extends bindings.StubMessageHandler
|
| + implements bindings.StubControl<WebSocket> {
|
| WebSocket _impl;
|
|
|
| - WebSocketStub.fromEndpoint(
|
| + _WebSocketStubControl.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint, [WebSocket impl])
|
| : super.fromEndpoint(endpoint, autoBegin: impl != null) {
|
| _impl = impl;
|
| }
|
|
|
| - WebSocketStub.fromHandle(
|
| + _WebSocketStubControl.fromHandle(
|
| core.MojoHandle handle, [WebSocket impl])
|
| : super.fromHandle(handle, autoBegin: impl != null) {
|
| _impl = impl;
|
| }
|
|
|
| - WebSocketStub.unbound([this._impl]) : super.unbound();
|
| -
|
| - static WebSocketStub newFromEndpoint(
|
| - core.MojoMessagePipeEndpoint endpoint) {
|
| - assert(endpoint.setDescription("For WebSocketStub"));
|
| - return new WebSocketStub.fromEndpoint(endpoint);
|
| - }
|
| + _WebSocketStubControl.unbound([this._impl]) : super.unbound();
|
|
|
|
|
|
|
| @@ -1129,9 +1123,10 @@ class WebSocketStub extends bindings.Stub {
|
| }
|
| }
|
|
|
| + @override
|
| String toString() {
|
| var superString = super.toString();
|
| - return "WebSocketStub($superString)";
|
| + return "_WebSocketStubControl($superString)";
|
| }
|
|
|
| int get version => 0;
|
| @@ -1145,6 +1140,44 @@ class WebSocketStub extends bindings.Stub {
|
| }
|
| }
|
|
|
| +class WebSocketStub
|
| + extends bindings.Stub<WebSocket>
|
| + implements WebSocket {
|
| + WebSocketStub.fromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint, [WebSocket impl])
|
| + : super(new _WebSocketStubControl.fromEndpoint(endpoint, impl));
|
| +
|
| + WebSocketStub.fromHandle(
|
| + core.MojoHandle handle, [WebSocket impl])
|
| + : super(new _WebSocketStubControl.fromHandle(handle, impl));
|
| +
|
| + WebSocketStub.unbound([WebSocket impl])
|
| + : super(new _WebSocketStubControl.unbound(impl));
|
| +
|
| + static WebSocketStub newFromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) {
|
| + assert(endpoint.setDescription("For WebSocketStub"));
|
| + return new WebSocketStub.fromEndpoint(endpoint);
|
| + }
|
| +
|
| + static service_describer.ServiceDescription get serviceDescription =>
|
| + _WebSocketStubControl.serviceDescription;
|
| +
|
| +
|
| + void connect(String url, List<String> protocols, String origin, core.MojoDataPipeConsumer sendStream, Object client) {
|
| + return impl.connect(url, protocols, origin, sendStream, client);
|
| + }
|
| + void send(bool fin, WebSocketMessageType type, int numBytes) {
|
| + return impl.send(fin, type, numBytes);
|
| + }
|
| + void flowControl(int quota) {
|
| + return impl.flowControl(quota);
|
| + }
|
| + void close_(int code, String reason) {
|
| + return impl.close_(code, reason);
|
| + }
|
| +}
|
| +
|
| const int _webSocketClientMethodDidConnectName = 0;
|
| const int _webSocketClientMethodDidReceiveDataName = 1;
|
| const int _webSocketClientMethodDidReceiveFlowControlName = 2;
|
| @@ -1171,9 +1204,9 @@ abstract class WebSocketClient {
|
| void didClose(bool wasClean, int code, String reason);
|
| }
|
|
|
| -
|
| -class _WebSocketClientProxyControl extends bindings.ProxyMessageHandler
|
| - implements bindings.ProxyControl {
|
| +class _WebSocketClientProxyControl
|
| + extends bindings.ProxyMessageHandler
|
| + implements bindings.ProxyControl {
|
| _WebSocketClientProxyControl.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
|
|
|
| @@ -1187,7 +1220,6 @@ class _WebSocketClientProxyControl extends bindings.ProxyMessageHandler
|
|
|
| String get serviceName => WebSocketClient.serviceName;
|
|
|
| - @override
|
| void handleResponse(bindings.ServiceMessage message) {
|
| switch (message.header.type) {
|
| default:
|
| @@ -1204,9 +1236,9 @@ class _WebSocketClientProxyControl extends bindings.ProxyMessageHandler
|
| }
|
| }
|
|
|
| -
|
| -class WebSocketClientProxy extends bindings.Proxy
|
| - implements WebSocketClient {
|
| +class WebSocketClientProxy
|
| + extends bindings.Proxy
|
| + implements WebSocketClient {
|
| WebSocketClientProxy.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint)
|
| : super(new _WebSocketClientProxyControl.fromEndpoint(endpoint));
|
| @@ -1289,29 +1321,24 @@ class WebSocketClientProxy extends bindings.Proxy
|
| }
|
| }
|
|
|
| -
|
| -class WebSocketClientStub extends bindings.Stub {
|
| +class _WebSocketClientStubControl
|
| + extends bindings.StubMessageHandler
|
| + implements bindings.StubControl<WebSocketClient> {
|
| WebSocketClient _impl;
|
|
|
| - WebSocketClientStub.fromEndpoint(
|
| + _WebSocketClientStubControl.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint, [WebSocketClient impl])
|
| : super.fromEndpoint(endpoint, autoBegin: impl != null) {
|
| _impl = impl;
|
| }
|
|
|
| - WebSocketClientStub.fromHandle(
|
| + _WebSocketClientStubControl.fromHandle(
|
| core.MojoHandle handle, [WebSocketClient impl])
|
| : super.fromHandle(handle, autoBegin: impl != null) {
|
| _impl = impl;
|
| }
|
|
|
| - WebSocketClientStub.unbound([this._impl]) : super.unbound();
|
| -
|
| - static WebSocketClientStub newFromEndpoint(
|
| - core.MojoMessagePipeEndpoint endpoint) {
|
| - assert(endpoint.setDescription("For WebSocketClientStub"));
|
| - return new WebSocketClientStub.fromEndpoint(endpoint);
|
| - }
|
| + _WebSocketClientStubControl.unbound([this._impl]) : super.unbound();
|
|
|
|
|
|
|
| @@ -1376,9 +1403,10 @@ class WebSocketClientStub extends bindings.Stub {
|
| }
|
| }
|
|
|
| + @override
|
| String toString() {
|
| var superString = super.toString();
|
| - return "WebSocketClientStub($superString)";
|
| + return "_WebSocketClientStubControl($superString)";
|
| }
|
|
|
| int get version => 0;
|
| @@ -1392,5 +1420,46 @@ class WebSocketClientStub extends bindings.Stub {
|
| }
|
| }
|
|
|
| +class WebSocketClientStub
|
| + extends bindings.Stub<WebSocketClient>
|
| + implements WebSocketClient {
|
| + WebSocketClientStub.fromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint, [WebSocketClient impl])
|
| + : super(new _WebSocketClientStubControl.fromEndpoint(endpoint, impl));
|
| +
|
| + WebSocketClientStub.fromHandle(
|
| + core.MojoHandle handle, [WebSocketClient impl])
|
| + : super(new _WebSocketClientStubControl.fromHandle(handle, impl));
|
| +
|
| + WebSocketClientStub.unbound([WebSocketClient impl])
|
| + : super(new _WebSocketClientStubControl.unbound(impl));
|
| +
|
| + static WebSocketClientStub newFromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) {
|
| + assert(endpoint.setDescription("For WebSocketClientStub"));
|
| + return new WebSocketClientStub.fromEndpoint(endpoint);
|
| + }
|
| +
|
| + static service_describer.ServiceDescription get serviceDescription =>
|
| + _WebSocketClientStubControl.serviceDescription;
|
| +
|
| +
|
| + void didConnect(String selectedSubprotocol, String extensions, core.MojoDataPipeConsumer receiveStream) {
|
| + return impl.didConnect(selectedSubprotocol, extensions, receiveStream);
|
| + }
|
| + void didReceiveData(bool fin, WebSocketMessageType type, int numBytes) {
|
| + return impl.didReceiveData(fin, type, numBytes);
|
| + }
|
| + void didReceiveFlowControl(int quota) {
|
| + return impl.didReceiveFlowControl(quota);
|
| + }
|
| + void didFail(String message) {
|
| + return impl.didFail(message);
|
| + }
|
| + void didClose(bool wasClean, int code, String reason) {
|
| + return impl.didClose(wasClean, code, reason);
|
| + }
|
| +}
|
| +
|
|
|
|
|
|
|