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

Unified Diff: mojo/dart/packages/mojo_services/lib/mojo/ui/views.mojom.dart

Issue 2006093002: Dart: Futures -> Callbacks. (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Cleanup 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
Index: mojo/dart/packages/mojo_services/lib/mojo/ui/views.mojom.dart
diff --git a/mojo/dart/packages/mojo_services/lib/mojo/ui/views.mojom.dart b/mojo/dart/packages/mojo_services/lib/mojo/ui/views.mojom.dart
index 065d45b1f9c3324ab06247f272c828ce9c5c06fc..b1ca79f6f35c67b1b0fc2cc195a9a39a8aae438d 100644
--- a/mojo/dart/packages/mojo_services/lib/mojo/ui/views.mojom.dart
+++ b/mojo/dart/packages/mojo_services/lib/mojo/ui/views.mojom.dart
@@ -22,6 +22,9 @@ class _ViewGetTokenParams extends bindings.Struct {
_ViewGetTokenParams() : super(kVersions.last.size);
+ _ViewGetTokenParams.init(
+ ) : super(kVersions.last.size);
+
static _ViewGetTokenParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -81,6 +84,10 @@ class ViewGetTokenResponseParams extends bindings.Struct {
ViewGetTokenResponseParams() : super(kVersions.last.size);
+ ViewGetTokenResponseParams.init(
+ view_token_mojom.ViewToken this.token
+ ) : super(kVersions.last.size);
+
static ViewGetTokenResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -154,6 +161,10 @@ class _ViewGetServiceProviderParams extends bindings.Struct {
_ViewGetServiceProviderParams() : super(kVersions.last.size);
+ _ViewGetServiceProviderParams.init(
+ service_provider_mojom.ServiceProviderInterfaceRequest this.serviceProvider
+ ) : super(kVersions.last.size);
+
static _ViewGetServiceProviderParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -225,6 +236,10 @@ class _ViewCreateSceneParams extends bindings.Struct {
_ViewCreateSceneParams() : super(kVersions.last.size);
+ _ViewCreateSceneParams.init(
+ scenes_mojom.SceneInterfaceRequest this.scene
+ ) : super(kVersions.last.size);
+
static _ViewCreateSceneParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -296,6 +311,10 @@ class _ViewGetContainerParams extends bindings.Struct {
_ViewGetContainerParams() : super(kVersions.last.size);
+ _ViewGetContainerParams.init(
+ view_containers_mojom.ViewContainerInterfaceRequest this.container
+ ) : super(kVersions.last.size);
+
static _ViewGetContainerParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -368,6 +387,11 @@ class _ViewListenerOnPropertiesChangedParams extends bindings.Struct {
_ViewListenerOnPropertiesChangedParams() : super(kVersions.last.size);
+ _ViewListenerOnPropertiesChangedParams.init(
+ int this.sceneVersion,
+ view_properties_mojom.ViewProperties this.properties
+ ) : super(kVersions.last.size);
+
static _ViewListenerOnPropertiesChangedParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -453,6 +477,9 @@ class ViewListenerOnPropertiesChangedResponseParams extends bindings.Struct {
ViewListenerOnPropertiesChangedResponseParams() : super(kVersions.last.size);
+ ViewListenerOnPropertiesChangedResponseParams.init(
+ ) : super(kVersions.last.size);
+
static ViewListenerOnPropertiesChangedResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
@@ -509,14 +536,17 @@ const int _viewMethodCreateSceneName = 2;
const int _viewMethodGetContainerName = 3;
class _ViewServiceDescription 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 View {
@@ -541,7 +571,7 @@ abstract class View {
s.connectToService(url, p, name);
return p;
}
- dynamic getToken([Function responseFactory = null]);
+ void getToken(void callback(view_token_mojom.ViewToken token));
void getServiceProvider(service_provider_mojom.ServiceProviderInterfaceRequest serviceProvider);
void createScene(scenes_mojom.SceneInterfaceRequest scene);
void getContainer(view_containers_mojom.ViewContainerInterfaceRequest container);
@@ -594,18 +624,14 @@ class _ViewProxyControl
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.token );
break;
default:
proxyError("Unexpected message type: ${message.header.type}");
@@ -650,16 +676,18 @@ class ViewProxy
}
- dynamic getToken([Function responseFactory = null]) {
+ void getToken(void callback(view_token_mojom.ViewToken token)) {
if (impl != null) {
- return new Future(() => impl.getToken(_ViewStubControl._viewGetTokenResponseParamsFactory));
+ impl.getToken(callback);
+ return;
}
var params = new _ViewGetTokenParams();
- return ctrl.sendMessageWithRequestId(
+ ctrl.sendMessageWithRequestId(
params,
_viewMethodGetTokenName,
-1,
- bindings.MessageHeader.kMessageExpectsResponse);
+ bindings.MessageHeader.kMessageExpectsResponse,
+ callback);
}
void getServiceProvider(service_provider_mojom.ServiceProviderInterfaceRequest serviceProvider) {
if (impl != null) {
@@ -727,41 +755,31 @@ class _ViewStubControl
String get serviceName => View.serviceName;
- static ViewGetTokenResponseParams _viewGetTokenResponseParamsFactory(view_token_mojom.ViewToken token) {
- var result = new ViewGetTokenResponseParams();
- result.token = token;
- return result;
+ Function _viewGetTokenResponseParamsResponder(
+ int requestId) {
+ return (view_token_mojom.ViewToken token) {
+ var result = new ViewGetTokenResponseParams();
+ result.token = token;
+ sendResponse(buildResponseWithId(
+ result,
+ _viewMethodGetTokenName,
+ requestId,
+ bindings.MessageHeader.kMessageIsResponse));
+ };
}
- dynamic handleMessage(bindings.ServiceMessage message) {
+ 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");
}
switch (message.header.type) {
case _viewMethodGetTokenName:
- var response = _impl.getToken(_viewGetTokenResponseParamsFactory);
- if (response is Future) {
- return response.then((response) {
- if (response != null) {
- return buildResponseWithId(
- response,
- _viewMethodGetTokenName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
- });
- } else if (response != null) {
- return buildResponseWithId(
- response,
- _viewMethodGetTokenName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
+ _impl.getToken(_viewGetTokenResponseParamsResponder(message.header.requestId));
break;
case _viewMethodGetServiceProviderName:
var params = _ViewGetServiceProviderParams.deserialize(
@@ -782,7 +800,6 @@ class _ViewStubControl
throw new bindings.MojoCodecError("Unexpected message name");
break;
}
- return null;
}
View get impl => _impl;
@@ -836,8 +853,8 @@ class ViewStub
}
- dynamic getToken([Function responseFactory = null]) {
- return impl.getToken(responseFactory);
+ void getToken(void callback(view_token_mojom.ViewToken token)) {
+ return impl.getToken(callback);
}
void getServiceProvider(service_provider_mojom.ServiceProviderInterfaceRequest serviceProvider) {
return impl.getServiceProvider(serviceProvider);
@@ -853,14 +870,17 @@ class ViewStub
const int _viewListenerMethodOnPropertiesChangedName = 0;
class _ViewListenerServiceDescription 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 ViewListener {
@@ -885,7 +905,7 @@ abstract class ViewListener {
s.connectToService(url, p, name);
return p;
}
- dynamic onPropertiesChanged(int sceneVersion,view_properties_mojom.ViewProperties properties,[Function responseFactory = null]);
+ void onPropertiesChanged(int sceneVersion,view_properties_mojom.ViewProperties properties,void callback());
}
abstract class ViewListenerInterface
@@ -935,18 +955,14 @@ class _ViewListenerProxyControl
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();
break;
default:
proxyError("Unexpected message type: ${message.header.type}");
@@ -991,18 +1007,20 @@ class ViewListenerProxy
}
- dynamic onPropertiesChanged(int sceneVersion,view_properties_mojom.ViewProperties properties,[Function responseFactory = null]) {
+ void onPropertiesChanged(int sceneVersion,view_properties_mojom.ViewProperties properties,void callback()) {
if (impl != null) {
- return new Future(() => impl.onPropertiesChanged(sceneVersion,properties,_ViewListenerStubControl._viewListenerOnPropertiesChangedResponseParamsFactory));
+ impl.onPropertiesChanged(sceneVersion,properties,callback);
+ return;
}
var params = new _ViewListenerOnPropertiesChangedParams();
params.sceneVersion = sceneVersion;
params.properties = properties;
- return ctrl.sendMessageWithRequestId(
+ ctrl.sendMessageWithRequestId(
params,
_viewListenerMethodOnPropertiesChangedName,
-1,
- bindings.MessageHeader.kMessageExpectsResponse);
+ bindings.MessageHeader.kMessageExpectsResponse,
+ callback);
}
}
@@ -1028,16 +1046,23 @@ class _ViewListenerStubControl
String get serviceName => ViewListener.serviceName;
- static ViewListenerOnPropertiesChangedResponseParams _viewListenerOnPropertiesChangedResponseParamsFactory() {
- var result = new ViewListenerOnPropertiesChangedResponseParams();
- return result;
+ Function _viewListenerOnPropertiesChangedResponseParamsResponder(
+ int requestId) {
+ return () {
+ var result = new ViewListenerOnPropertiesChangedResponseParams();
+ sendResponse(buildResponseWithId(
+ result,
+ _viewListenerMethodOnPropertiesChangedName,
+ requestId,
+ bindings.MessageHeader.kMessageIsResponse));
+ };
}
- dynamic handleMessage(bindings.ServiceMessage message) {
+ 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");
@@ -1046,30 +1071,12 @@ class _ViewListenerStubControl
case _viewListenerMethodOnPropertiesChangedName:
var params = _ViewListenerOnPropertiesChangedParams.deserialize(
message.payload);
- var response = _impl.onPropertiesChanged(params.sceneVersion,params.properties,_viewListenerOnPropertiesChangedResponseParamsFactory);
- if (response is Future) {
- return response.then((response) {
- if (response != null) {
- return buildResponseWithId(
- response,
- _viewListenerMethodOnPropertiesChangedName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
- });
- } else if (response != null) {
- return buildResponseWithId(
- response,
- _viewListenerMethodOnPropertiesChangedName,
- message.header.requestId,
- bindings.MessageHeader.kMessageIsResponse);
- }
+ _impl.onPropertiesChanged(params.sceneVersion, params.properties, _viewListenerOnPropertiesChangedResponseParamsResponder(message.header.requestId));
break;
default:
throw new bindings.MojoCodecError("Unexpected message name");
break;
}
- return null;
}
ViewListener get impl => _impl;
@@ -1123,8 +1130,8 @@ class ViewListenerStub
}
- dynamic onPropertiesChanged(int sceneVersion,view_properties_mojom.ViewProperties properties,[Function responseFactory = null]) {
- return impl.onPropertiesChanged(sceneVersion,properties,responseFactory);
+ void onPropertiesChanged(int sceneVersion,view_properties_mojom.ViewProperties properties,void callback()) {
+ return impl.onPropertiesChanged(sceneVersion,properties,callback);
}
}

Powered by Google App Engine
This is Rietveld 408576698