Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(90)

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: mojo/dart/packages/mojo_services/lib/mojo/http_connection.mojom.dart

Issue 2006093002: Dart: Futures -> Callbacks. (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Move code from mojo_patch to proxy.dart Created 4 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« examples/dart/echo_client/lib/main.dart ('K') | « mojo/dart/packages/mojo_services/lib/mojo/host_resolver.mojom.dart ('k') | mojo/dart/packages/mojo_services/lib/mojo/http_message.mojom.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/dart/packages/mojo_services/lib/mojo/http_connection.mojom.dart
diff --git a/mojo/dart/packages/mojo_services/lib/mojo/http_connection.mojom.dart b/mojo/dart/packages/mojo_services/lib/mojo/http_connection.mojom.dart
index cfb69572dfd80cfb3ea8f1e534e614e27c74e6fc..b05bbd0c33577c24e3f8a19a11652d74eb9f7bfa 100644
--- a/mojo/dart/packages/mojo_services/lib/mojo/http_connection.mojom.dart
+++ b/mojo/dart/packages/mojo_services/lib/mojo/http_connection.mojom.dart
@@ -21,6 +21,10 @@ class _HttpConnectionSetSendBufferSizeParams extends bindings.Struct {
_HttpConnectionSetSendBufferSizeParams() : super(kVersions.last.size);
+ _HttpConnectionSetSendBufferSizeParams.init(
+ int this.size
+ ) : super(kVersions.last.size);
+
static _HttpConnectionSetSendBufferSizeParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -93,6 +97,10 @@ class HttpConnectionSetSendBufferSizeResponseParams extends bindings.Struct {
HttpConnectionSetSendBufferSizeResponseParams() : super(kVersions.last.size);
+ HttpConnectionSetSendBufferSizeResponseParams.init(
+ network_error_mojom.NetworkError this.result
+ ) : super(kVersions.last.size);
+
static HttpConnectionSetSendBufferSizeResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -166,6 +174,10 @@ class _HttpConnectionSetReceiveBufferSizeParams extends bindings.Struct {
_HttpConnectionSetReceiveBufferSizeParams() : super(kVersions.last.size);
+ _HttpConnectionSetReceiveBufferSizeParams.init(
+ int this.size
+ ) : super(kVersions.last.size);
+
static _HttpConnectionSetReceiveBufferSizeParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -238,6 +250,10 @@ class HttpConnectionSetReceiveBufferSizeResponseParams extends bindings.Struct {
HttpConnectionSetReceiveBufferSizeResponseParams() : super(kVersions.last.size);
+ HttpConnectionSetReceiveBufferSizeResponseParams.init(
+ network_error_mojom.NetworkError this.result
+ ) : super(kVersions.last.size);
+
static HttpConnectionSetReceiveBufferSizeResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -311,6 +327,10 @@ class _HttpConnectionDelegateOnReceivedRequestParams extends bindings.Struct {
_HttpConnectionDelegateOnReceivedRequestParams() : super(kVersions.last.size);
+ _HttpConnectionDelegateOnReceivedRequestParams.init(
+ http_message_mojom.HttpRequest this.request
+ ) : super(kVersions.last.size);
+
static _HttpConnectionDelegateOnReceivedRequestParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -383,6 +403,10 @@ class HttpConnectionDelegateOnReceivedRequestResponseParams extends bindings.Str
HttpConnectionDelegateOnReceivedRequestResponseParams() : super(kVersions.last.size);
+ HttpConnectionDelegateOnReceivedRequestResponseParams.init(
+ http_message_mojom.HttpResponse this.response
+ ) : super(kVersions.last.size);
+
static HttpConnectionDelegateOnReceivedRequestResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -455,6 +479,10 @@ class _HttpConnectionDelegateOnReceivedWebSocketRequestParams extends bindings.S
_HttpConnectionDelegateOnReceivedWebSocketRequestParams() : super(kVersions.last.size);
+ _HttpConnectionDelegateOnReceivedWebSocketRequestParams.init(
+ http_message_mojom.HttpRequest this.request
+ ) : super(kVersions.last.size);
+
static _HttpConnectionDelegateOnReceivedWebSocketRequestParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -529,6 +557,12 @@ class HttpConnectionDelegateOnReceivedWebSocketRequestResponseParams extends bin
HttpConnectionDelegateOnReceivedWebSocketRequestResponseParams() : super(kVersions.last.size);
+ HttpConnectionDelegateOnReceivedWebSocketRequestResponseParams.init(
+ web_socket_mojom.WebSocketInterfaceRequest this.webSocket,
+ core.MojoDataPipeConsumer this.sendStream,
+ web_socket_mojom.WebSocketClientInterface this.client
+ ) : super(kVersions.last.size);
+
static HttpConnectionDelegateOnReceivedWebSocketRequestResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -619,14 +653,17 @@ const int _httpConnectionMethodSetSendBufferSizeName = 0;
const int _httpConnectionMethodSetReceiveBufferSizeName = 1;
class _HttpConnectionServiceDescription implements service_describer.ServiceDescription {
- dynamic getTopLevelInterface([Function responseFactory]) =>
- responseFactory(null);
+ void getTopLevelInterface(Function responder) {
+ responder(null);
+ }
- dynamic getTypeDefinition(String typeKey, [Function responseFactory]) =>
- responseFactory(null);
+ void getTypeDefinition(String typeKey, Function responder) {
+ responder(null);
+ }
- dynamic getAllTypeDefinitions([Function responseFactory]) =>
- responseFactory(null);
+ void getAllTypeDefinitions(Function responder) {
+ responder(null);
+ }
}
abstract class HttpConnection {
@@ -651,8 +688,8 @@ abstract class HttpConnection {
s.connectToService(url, p, name);
return p;
}
- dynamic setSendBufferSize(int size,[Function responseFactory = null]);
- dynamic setReceiveBufferSize(int size,[Function responseFactory = null]);
+ void setSendBufferSize(int size,void callback(network_error_mojom.NetworkError result));
+ void setReceiveBufferSize(int size,void callback(network_error_mojom.NetworkError result));
}
abstract class HttpConnectionInterface
@@ -695,18 +732,14 @@ class _HttpConnectionProxyControl
proxyError("Expected a message with a valid request Id.");
return;
}
- Completer c = completerMap[message.header.requestId];
- if (c == null) {
+ Function callback = callbackMap[message.header.requestId];
+ if (callback == null) {
proxyError(
"Message had unknown request Id: ${message.header.requestId}");
return;
}
- completerMap.remove(message.header.requestId);
- if (c.isCompleted) {
- proxyError("Response completer already completed");
- return;
- }
- c.complete(r);
+ callbackMap.remove(message.header.requestId);
+ callback(r.result );
break;
case _httpConnectionMethodSetReceiveBufferSizeName:
var r = HttpConnectionSetReceiveBufferSizeResponseParams.deserialize(
@@ -715,18 +748,14 @@ class _HttpConnectionProxyControl
proxyError("Expected a message with a valid request Id.");
return;
}
- Completer c = completerMap[message.header.requestId];
- if (c == null) {
+ Function callback = callbackMap[message.header.requestId];
+ if (callback == null) {
proxyError(
"Message had unknown request Id: ${message.header.requestId}");
return;
}
- completerMap.remove(message.header.requestId);
- if (c.isCompleted) {
- proxyError("Response completer already completed");
- return;
- }
- c.complete(r);
+ callbackMap.remove(message.header.requestId);
+ callback(r.result );
break;
default:
proxyError("Unexpected message type: ${message.header.type}");
@@ -769,23 +798,25 @@ class HttpConnectionProxy
}
- dynamic setSendBufferSize(int size,[Function responseFactory = null]) {
+ void setSendBufferSize(int size,void callback(network_error_mojom.NetworkError result)) {
var params = new _HttpConnectionSetSendBufferSizeParams();
params.size = size;
- return ctrl.sendMessageWithRequestId(
+ ctrl.sendMessageWithRequestId(
params,
_httpConnectionMethodSetSendBufferSizeName,
-1,
- bindings.MessageHeader.kMessageExpectsResponse);
+ bindings.MessageHeader.kMessageExpectsResponse,
+ callback);
}
- dynamic setReceiveBufferSize(int size,[Function responseFactory = null]) {
+ void setReceiveBufferSize(int size,void callback(network_error_mojom.NetworkError result)) {
var params = new _HttpConnectionSetReceiveBufferSizeParams();
params.size = size;
- return ctrl.sendMessageWithRequestId(
+ ctrl.sendMessageWithRequestId(
params,
_httpConnectionMethodSetReceiveBufferSizeName,
-1,
- bindings.MessageHeader.kMessageExpectsResponse);
+ bindings.MessageHeader.kMessageExpectsResponse,
+ callback);
}
}
@@ -811,22 +842,36 @@ class _HttpConnectionStubControl
String get serviceName => HttpConnection.serviceName;
- HttpConnectionSetSendBufferSizeResponseParams _httpConnectionSetSendBufferSizeResponseParamsFactory(network_error_mojom.NetworkError result) {
- var result = new HttpConnectionSetSendBufferSizeResponseParams();
- result.result = result;
- return result;
- }
- HttpConnectionSetReceiveBufferSizeResponseParams _httpConnectionSetReceiveBufferSizeResponseParamsFactory(network_error_mojom.NetworkError result) {
- var result = new HttpConnectionSetReceiveBufferSizeResponseParams();
- result.result = result;
- return result;
- }
-
- dynamic handleMessage(bindings.ServiceMessage message) {
+ Function _httpConnectionSetSendBufferSizeResponseParamsResponder(
+ int requestId) {
+ return (network_error_mojom.NetworkError result) {
+ var result = new HttpConnectionSetSendBufferSizeResponseParams();
+ result.result = result;
+ sendResponse(buildResponseWithId(
+ result,
+ _httpConnectionMethodSetSendBufferSizeName,
+ requestId,
+ bindings.MessageHeader.kMessageIsResponse));
+ };
+ }
+ Function _httpConnectionSetReceiveBufferSizeResponseParamsResponder(
+ int requestId) {
+ return (network_error_mojom.NetworkError result) {
+ var result = new HttpConnectionSetReceiveBufferSizeResponseParams();
+ result.result = result;
+ sendResponse(buildResponseWithId(
+ result,
+ _httpConnectionMethodSetReceiveBufferSizeName,
+ requestId,
+ bindings.MessageHeader.kMessageIsResponse));
+ };
+ }
+
+ void handleMessage(bindings.ServiceMessage message) {
if (bindings.ControlMessageHandler.isControlMessage(message)) {
- return bindings.ControlMessageHandler.handleMessage(this,
- 0,
- message);
+ bindings.ControlMessageHandler.handleMessage(
+ this, 0, message);
+ return;
}
if (_impl == null) {
throw new core.MojoApiError("$this has no implementation set");
@@ -835,52 +880,17 @@ class _HttpConnectionStubControl
case _httpConnectionMethodSetSendBufferSizeName:
var params = _HttpConnectionSetSendBufferSizeParams.deserialize(
message.payload);
- var response = _impl.setSendBufferSize(params.size,_httpConnectionSetSendBufferSizeResponseParamsFactory);
- if (response is Future) {
- return response.then((response) {
- if (response != null) {
- return buildResponseWithId(
- response,
- _httpConnectionMethodSetSendBufferSizeName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
- });
- } else if (response != null) {
- return buildResponseWithId(
- response,
- _httpConnectionMethodSetSendBufferSizeName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
+ _impl.setSendBufferSize(params.size, _httpConnectionSetSendBufferSizeResponseParamsResponder(message.header.requestId));
break;
case _httpConnectionMethodSetReceiveBufferSizeName:
var params = _HttpConnectionSetReceiveBufferSizeParams.deserialize(
message.payload);
- var response = _impl.setReceiveBufferSize(params.size,_httpConnectionSetReceiveBufferSizeResponseParamsFactory);
- if (response is Future) {
- return response.then((response) {
- if (response != null) {
- return buildResponseWithId(
- response,
- _httpConnectionMethodSetReceiveBufferSizeName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
- });
- } else if (response != null) {
- return buildResponseWithId(
- response,
- _httpConnectionMethodSetReceiveBufferSizeName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
+ _impl.setReceiveBufferSize(params.size, _httpConnectionSetReceiveBufferSizeResponseParamsResponder(message.header.requestId));
break;
default:
throw new bindings.MojoCodecError("Unexpected message name");
break;
}
- return null;
}
HttpConnection get impl => _impl;
@@ -934,11 +944,11 @@ class HttpConnectionStub
}
- dynamic setSendBufferSize(int size,[Function responseFactory = null]) {
- return impl.setSendBufferSize(size,responseFactory);
+ void setSendBufferSize(int size,void callback(network_error_mojom.NetworkError result)) {
+ return impl.setSendBufferSize(size,callback);
}
- dynamic setReceiveBufferSize(int size,[Function responseFactory = null]) {
- return impl.setReceiveBufferSize(size,responseFactory);
+ void setReceiveBufferSize(int size,void callback(network_error_mojom.NetworkError result)) {
+ return impl.setReceiveBufferSize(size,callback);
}
}
@@ -946,14 +956,17 @@ const int _httpConnectionDelegateMethodOnReceivedRequestName = 0;
const int _httpConnectionDelegateMethodOnReceivedWebSocketRequestName = 1;
class _HttpConnectionDelegateServiceDescription implements service_describer.ServiceDescription {
- dynamic getTopLevelInterface([Function responseFactory]) =>
- responseFactory(null);
+ void getTopLevelInterface(Function responder) {
+ responder(null);
+ }
- dynamic getTypeDefinition(String typeKey, [Function responseFactory]) =>
- responseFactory(null);
+ void getTypeDefinition(String typeKey, Function responder) {
+ responder(null);
+ }
- dynamic getAllTypeDefinitions([Function responseFactory]) =>
- responseFactory(null);
+ void getAllTypeDefinitions(Function responder) {
+ responder(null);
+ }
}
abstract class HttpConnectionDelegate {
@@ -978,8 +991,8 @@ abstract class HttpConnectionDelegate {
s.connectToService(url, p, name);
return p;
}
- dynamic onReceivedRequest(http_message_mojom.HttpRequest request,[Function responseFactory = null]);
- dynamic onReceivedWebSocketRequest(http_message_mojom.HttpRequest request,[Function responseFactory = null]);
+ void onReceivedRequest(http_message_mojom.HttpRequest request,void callback(http_message_mojom.HttpResponse response));
+ void onReceivedWebSocketRequest(http_message_mojom.HttpRequest request,void callback(web_socket_mojom.WebSocketInterfaceRequest webSocket, core.MojoDataPipeConsumer sendStream, web_socket_mojom.WebSocketClientInterface client));
}
abstract class HttpConnectionDelegateInterface
@@ -1022,18 +1035,14 @@ class _HttpConnectionDelegateProxyControl
proxyError("Expected a message with a valid request Id.");
return;
}
- Completer c = completerMap[message.header.requestId];
- if (c == null) {
+ Function callback = callbackMap[message.header.requestId];
+ if (callback == null) {
proxyError(
"Message had unknown request Id: ${message.header.requestId}");
return;
}
- completerMap.remove(message.header.requestId);
- if (c.isCompleted) {
- proxyError("Response completer already completed");
- return;
- }
- c.complete(r);
+ callbackMap.remove(message.header.requestId);
+ callback(r.response );
break;
case _httpConnectionDelegateMethodOnReceivedWebSocketRequestName:
var r = HttpConnectionDelegateOnReceivedWebSocketRequestResponseParams.deserialize(
@@ -1042,18 +1051,14 @@ class _HttpConnectionDelegateProxyControl
proxyError("Expected a message with a valid request Id.");
return;
}
- Completer c = completerMap[message.header.requestId];
- if (c == null) {
+ Function callback = callbackMap[message.header.requestId];
+ if (callback == null) {
proxyError(
"Message had unknown request Id: ${message.header.requestId}");
return;
}
- completerMap.remove(message.header.requestId);
- if (c.isCompleted) {
- proxyError("Response completer already completed");
- return;
- }
- c.complete(r);
+ callbackMap.remove(message.header.requestId);
+ callback(r.webSocket , r.sendStream , r.client );
break;
default:
proxyError("Unexpected message type: ${message.header.type}");
@@ -1096,23 +1101,25 @@ class HttpConnectionDelegateProxy
}
- dynamic onReceivedRequest(http_message_mojom.HttpRequest request,[Function responseFactory = null]) {
+ void onReceivedRequest(http_message_mojom.HttpRequest request,void callback(http_message_mojom.HttpResponse response)) {
var params = new _HttpConnectionDelegateOnReceivedRequestParams();
params.request = request;
- return ctrl.sendMessageWithRequestId(
+ ctrl.sendMessageWithRequestId(
params,
_httpConnectionDelegateMethodOnReceivedRequestName,
-1,
- bindings.MessageHeader.kMessageExpectsResponse);
+ bindings.MessageHeader.kMessageExpectsResponse,
+ callback);
}
- dynamic onReceivedWebSocketRequest(http_message_mojom.HttpRequest request,[Function responseFactory = null]) {
+ void onReceivedWebSocketRequest(http_message_mojom.HttpRequest request,void callback(web_socket_mojom.WebSocketInterfaceRequest webSocket, core.MojoDataPipeConsumer sendStream, web_socket_mojom.WebSocketClientInterface client)) {
var params = new _HttpConnectionDelegateOnReceivedWebSocketRequestParams();
params.request = request;
- return ctrl.sendMessageWithRequestId(
+ ctrl.sendMessageWithRequestId(
params,
_httpConnectionDelegateMethodOnReceivedWebSocketRequestName,
-1,
- bindings.MessageHeader.kMessageExpectsResponse);
+ bindings.MessageHeader.kMessageExpectsResponse,
+ callback);
}
}
@@ -1138,24 +1145,38 @@ class _HttpConnectionDelegateStubControl
String get serviceName => HttpConnectionDelegate.serviceName;
- HttpConnectionDelegateOnReceivedRequestResponseParams _httpConnectionDelegateOnReceivedRequestResponseParamsFactory(http_message_mojom.HttpResponse response) {
- var result = new HttpConnectionDelegateOnReceivedRequestResponseParams();
- result.response = response;
- return result;
- }
- HttpConnectionDelegateOnReceivedWebSocketRequestResponseParams _httpConnectionDelegateOnReceivedWebSocketRequestResponseParamsFactory(web_socket_mojom.WebSocketInterfaceRequest webSocket, core.MojoDataPipeConsumer sendStream, web_socket_mojom.WebSocketClientInterface client) {
- var result = new HttpConnectionDelegateOnReceivedWebSocketRequestResponseParams();
- result.webSocket = webSocket;
- result.sendStream = sendStream;
- result.client = client;
- return result;
- }
-
- dynamic handleMessage(bindings.ServiceMessage message) {
+ Function _httpConnectionDelegateOnReceivedRequestResponseParamsResponder(
+ int requestId) {
+ return (http_message_mojom.HttpResponse response) {
+ var result = new HttpConnectionDelegateOnReceivedRequestResponseParams();
+ result.response = response;
+ sendResponse(buildResponseWithId(
+ result,
+ _httpConnectionDelegateMethodOnReceivedRequestName,
+ requestId,
+ bindings.MessageHeader.kMessageIsResponse));
+ };
+ }
+ Function _httpConnectionDelegateOnReceivedWebSocketRequestResponseParamsResponder(
+ int requestId) {
+ return (web_socket_mojom.WebSocketInterfaceRequest webSocket, core.MojoDataPipeConsumer sendStream, web_socket_mojom.WebSocketClientInterface client) {
+ var result = new HttpConnectionDelegateOnReceivedWebSocketRequestResponseParams();
+ result.webSocket = webSocket;
+ result.sendStream = sendStream;
+ result.client = client;
+ sendResponse(buildResponseWithId(
+ result,
+ _httpConnectionDelegateMethodOnReceivedWebSocketRequestName,
+ requestId,
+ bindings.MessageHeader.kMessageIsResponse));
+ };
+ }
+
+ void handleMessage(bindings.ServiceMessage message) {
if (bindings.ControlMessageHandler.isControlMessage(message)) {
- return bindings.ControlMessageHandler.handleMessage(this,
- 0,
- message);
+ bindings.ControlMessageHandler.handleMessage(
+ this, 0, message);
+ return;
}
if (_impl == null) {
throw new core.MojoApiError("$this has no implementation set");
@@ -1164,52 +1185,17 @@ class _HttpConnectionDelegateStubControl
case _httpConnectionDelegateMethodOnReceivedRequestName:
var params = _HttpConnectionDelegateOnReceivedRequestParams.deserialize(
message.payload);
- var response = _impl.onReceivedRequest(params.request,_httpConnectionDelegateOnReceivedRequestResponseParamsFactory);
- if (response is Future) {
- return response.then((response) {
- if (response != null) {
- return buildResponseWithId(
- response,
- _httpConnectionDelegateMethodOnReceivedRequestName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
- });
- } else if (response != null) {
- return buildResponseWithId(
- response,
- _httpConnectionDelegateMethodOnReceivedRequestName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
+ _impl.onReceivedRequest(params.request, _httpConnectionDelegateOnReceivedRequestResponseParamsResponder(message.header.requestId));
break;
case _httpConnectionDelegateMethodOnReceivedWebSocketRequestName:
var params = _HttpConnectionDelegateOnReceivedWebSocketRequestParams.deserialize(
message.payload);
- var response = _impl.onReceivedWebSocketRequest(params.request,_httpConnectionDelegateOnReceivedWebSocketRequestResponseParamsFactory);
- if (response is Future) {
- return response.then((response) {
- if (response != null) {
- return buildResponseWithId(
- response,
- _httpConnectionDelegateMethodOnReceivedWebSocketRequestName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
- });
- } else if (response != null) {
- return buildResponseWithId(
- response,
- _httpConnectionDelegateMethodOnReceivedWebSocketRequestName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
+ _impl.onReceivedWebSocketRequest(params.request, _httpConnectionDelegateOnReceivedWebSocketRequestResponseParamsResponder(message.header.requestId));
break;
default:
throw new bindings.MojoCodecError("Unexpected message name");
break;
}
- return null;
}
HttpConnectionDelegate get impl => _impl;
@@ -1263,11 +1249,11 @@ class HttpConnectionDelegateStub
}
- dynamic onReceivedRequest(http_message_mojom.HttpRequest request,[Function responseFactory = null]) {
- return impl.onReceivedRequest(request,responseFactory);
+ void onReceivedRequest(http_message_mojom.HttpRequest request,void callback(http_message_mojom.HttpResponse response)) {
+ return impl.onReceivedRequest(request,callback);
}
- dynamic onReceivedWebSocketRequest(http_message_mojom.HttpRequest request,[Function responseFactory = null]) {
- return impl.onReceivedWebSocketRequest(request,responseFactory);
+ void onReceivedWebSocketRequest(http_message_mojom.HttpRequest request,void callback(web_socket_mojom.WebSocketInterfaceRequest webSocket, core.MojoDataPipeConsumer sendStream, web_socket_mojom.WebSocketClientInterface client)) {
+ return impl.onReceivedWebSocketRequest(request,callback);
}
}
« examples/dart/echo_client/lib/main.dart ('K') | « mojo/dart/packages/mojo_services/lib/mojo/host_resolver.mojom.dart ('k') | mojo/dart/packages/mojo_services/lib/mojo/http_message.mojom.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698