OLD | NEW |
1 // WARNING: DO NOT EDIT. This file was generated by a program. | 1 // WARNING: DO NOT EDIT. This file was generated by a program. |
2 // See $MOJO_SDK/tools/bindings/mojom_bindings_generator.py. | 2 // See $MOJO_SDK/tools/bindings/mojom_bindings_generator.py. |
3 | 3 |
4 library echo_service_mojom; | 4 library echo_service_mojom; |
5 import 'dart:async'; | 5 import 'dart:async'; |
6 import 'dart:collection'; | 6 import 'dart:collection'; |
7 import 'dart:convert'; | 7 import 'dart:convert'; |
8 import 'dart:io'; | 8 import 'dart:io'; |
9 import 'dart:typed_data'; | 9 import 'dart:typed_data'; |
10 import 'package:mojo/bindings.dart' as bindings; | 10 import 'package:mojo/bindings.dart' as bindings; |
11 import 'package:mojo/core.dart' as core; | 11 import 'package:mojo/core.dart' as core; |
12 import 'package:mojo/mojo/bindings/types/mojom_types.mojom.dart' as mojom_types; | 12 import 'package:mojo/mojo/bindings/types/mojom_types.mojom.dart' as mojom_types; |
13 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; | 13 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; |
14 | 14 |
15 | 15 |
16 | 16 |
17 class _EchoServiceEchoStringParams extends bindings.Struct { | 17 class _EchoServiceEchoStringParams extends bindings.Struct { |
18 static const List<bindings.StructDataHeader> kVersions = const [ | 18 static const List<bindings.StructDataHeader> kVersions = const [ |
19 const bindings.StructDataHeader(16, 0) | 19 const bindings.StructDataHeader(16, 0) |
20 ]; | 20 ]; |
21 String value = null; | 21 String value = null; |
22 | 22 |
23 _EchoServiceEchoStringParams() : super(kVersions.last.size); | 23 _EchoServiceEchoStringParams() : super(kVersions.last.size); |
24 | 24 |
| 25 _EchoServiceEchoStringParams.init( |
| 26 String this.value |
| 27 ) : super(kVersions.last.size); |
| 28 |
25 static _EchoServiceEchoStringParams deserialize(bindings.Message message) { | 29 static _EchoServiceEchoStringParams deserialize(bindings.Message message) { |
26 var decoder = new bindings.Decoder(message); | 30 var decoder = new bindings.Decoder(message); |
27 var result = decode(decoder); | 31 var result = decode(decoder); |
28 if (decoder.excessHandles != null) { | 32 if (decoder.excessHandles != null) { |
29 decoder.excessHandles.forEach((h) => h.close()); | 33 decoder.excessHandles.forEach((h) => h.close()); |
30 } | 34 } |
31 return result; | 35 return result; |
32 } | 36 } |
33 | 37 |
34 static _EchoServiceEchoStringParams decode(bindings.Decoder decoder0) { | 38 static _EchoServiceEchoStringParams decode(bindings.Decoder decoder0) { |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
87 | 91 |
88 | 92 |
89 class EchoServiceEchoStringResponseParams extends bindings.Struct { | 93 class EchoServiceEchoStringResponseParams extends bindings.Struct { |
90 static const List<bindings.StructDataHeader> kVersions = const [ | 94 static const List<bindings.StructDataHeader> kVersions = const [ |
91 const bindings.StructDataHeader(16, 0) | 95 const bindings.StructDataHeader(16, 0) |
92 ]; | 96 ]; |
93 String value = null; | 97 String value = null; |
94 | 98 |
95 EchoServiceEchoStringResponseParams() : super(kVersions.last.size); | 99 EchoServiceEchoStringResponseParams() : super(kVersions.last.size); |
96 | 100 |
| 101 EchoServiceEchoStringResponseParams.init( |
| 102 String this.value |
| 103 ) : super(kVersions.last.size); |
| 104 |
97 static EchoServiceEchoStringResponseParams deserialize(bindings.Message messag
e) { | 105 static EchoServiceEchoStringResponseParams deserialize(bindings.Message messag
e) { |
98 var decoder = new bindings.Decoder(message); | 106 var decoder = new bindings.Decoder(message); |
99 var result = decode(decoder); | 107 var result = decode(decoder); |
100 if (decoder.excessHandles != null) { | 108 if (decoder.excessHandles != null) { |
101 decoder.excessHandles.forEach((h) => h.close()); | 109 decoder.excessHandles.forEach((h) => h.close()); |
102 } | 110 } |
103 return result; | 111 return result; |
104 } | 112 } |
105 | 113 |
106 static EchoServiceEchoStringResponseParams decode(bindings.Decoder decoder0) { | 114 static EchoServiceEchoStringResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
160 | 168 |
161 class _EchoServiceDelayedEchoStringParams extends bindings.Struct { | 169 class _EchoServiceDelayedEchoStringParams extends bindings.Struct { |
162 static const List<bindings.StructDataHeader> kVersions = const [ | 170 static const List<bindings.StructDataHeader> kVersions = const [ |
163 const bindings.StructDataHeader(24, 0) | 171 const bindings.StructDataHeader(24, 0) |
164 ]; | 172 ]; |
165 String value = null; | 173 String value = null; |
166 int millis = 0; | 174 int millis = 0; |
167 | 175 |
168 _EchoServiceDelayedEchoStringParams() : super(kVersions.last.size); | 176 _EchoServiceDelayedEchoStringParams() : super(kVersions.last.size); |
169 | 177 |
| 178 _EchoServiceDelayedEchoStringParams.init( |
| 179 String this.value, |
| 180 int this.millis |
| 181 ) : super(kVersions.last.size); |
| 182 |
170 static _EchoServiceDelayedEchoStringParams deserialize(bindings.Message messag
e) { | 183 static _EchoServiceDelayedEchoStringParams deserialize(bindings.Message messag
e) { |
171 var decoder = new bindings.Decoder(message); | 184 var decoder = new bindings.Decoder(message); |
172 var result = decode(decoder); | 185 var result = decode(decoder); |
173 if (decoder.excessHandles != null) { | 186 if (decoder.excessHandles != null) { |
174 decoder.excessHandles.forEach((h) => h.close()); | 187 decoder.excessHandles.forEach((h) => h.close()); |
175 } | 188 } |
176 return result; | 189 return result; |
177 } | 190 } |
178 | 191 |
179 static _EchoServiceDelayedEchoStringParams decode(bindings.Decoder decoder0) { | 192 static _EchoServiceDelayedEchoStringParams decode(bindings.Decoder decoder0) { |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
245 | 258 |
246 | 259 |
247 class EchoServiceDelayedEchoStringResponseParams extends bindings.Struct { | 260 class EchoServiceDelayedEchoStringResponseParams extends bindings.Struct { |
248 static const List<bindings.StructDataHeader> kVersions = const [ | 261 static const List<bindings.StructDataHeader> kVersions = const [ |
249 const bindings.StructDataHeader(16, 0) | 262 const bindings.StructDataHeader(16, 0) |
250 ]; | 263 ]; |
251 String value = null; | 264 String value = null; |
252 | 265 |
253 EchoServiceDelayedEchoStringResponseParams() : super(kVersions.last.size); | 266 EchoServiceDelayedEchoStringResponseParams() : super(kVersions.last.size); |
254 | 267 |
| 268 EchoServiceDelayedEchoStringResponseParams.init( |
| 269 String this.value |
| 270 ) : super(kVersions.last.size); |
| 271 |
255 static EchoServiceDelayedEchoStringResponseParams deserialize(bindings.Message
message) { | 272 static EchoServiceDelayedEchoStringResponseParams deserialize(bindings.Message
message) { |
256 var decoder = new bindings.Decoder(message); | 273 var decoder = new bindings.Decoder(message); |
257 var result = decode(decoder); | 274 var result = decode(decoder); |
258 if (decoder.excessHandles != null) { | 275 if (decoder.excessHandles != null) { |
259 decoder.excessHandles.forEach((h) => h.close()); | 276 decoder.excessHandles.forEach((h) => h.close()); |
260 } | 277 } |
261 return result; | 278 return result; |
262 } | 279 } |
263 | 280 |
264 static EchoServiceDelayedEchoStringResponseParams decode(bindings.Decoder deco
der0) { | 281 static EchoServiceDelayedEchoStringResponseParams decode(bindings.Decoder deco
der0) { |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
316 } | 333 } |
317 | 334 |
318 | 335 |
319 class _EchoServiceSwapParams extends bindings.Struct { | 336 class _EchoServiceSwapParams extends bindings.Struct { |
320 static const List<bindings.StructDataHeader> kVersions = const [ | 337 static const List<bindings.StructDataHeader> kVersions = const [ |
321 const bindings.StructDataHeader(8, 0) | 338 const bindings.StructDataHeader(8, 0) |
322 ]; | 339 ]; |
323 | 340 |
324 _EchoServiceSwapParams() : super(kVersions.last.size); | 341 _EchoServiceSwapParams() : super(kVersions.last.size); |
325 | 342 |
| 343 _EchoServiceSwapParams.init( |
| 344 ) : super(kVersions.last.size); |
| 345 |
326 static _EchoServiceSwapParams deserialize(bindings.Message message) { | 346 static _EchoServiceSwapParams deserialize(bindings.Message message) { |
327 var decoder = new bindings.Decoder(message); | 347 var decoder = new bindings.Decoder(message); |
328 var result = decode(decoder); | 348 var result = decode(decoder); |
329 if (decoder.excessHandles != null) { | 349 if (decoder.excessHandles != null) { |
330 decoder.excessHandles.forEach((h) => h.close()); | 350 decoder.excessHandles.forEach((h) => h.close()); |
331 } | 351 } |
332 return result; | 352 return result; |
333 } | 353 } |
334 | 354 |
335 static _EchoServiceSwapParams decode(bindings.Decoder decoder0) { | 355 static _EchoServiceSwapParams decode(bindings.Decoder decoder0) { |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
374 } | 394 } |
375 | 395 |
376 | 396 |
377 class _EchoServiceQuitParams extends bindings.Struct { | 397 class _EchoServiceQuitParams extends bindings.Struct { |
378 static const List<bindings.StructDataHeader> kVersions = const [ | 398 static const List<bindings.StructDataHeader> kVersions = const [ |
379 const bindings.StructDataHeader(8, 0) | 399 const bindings.StructDataHeader(8, 0) |
380 ]; | 400 ]; |
381 | 401 |
382 _EchoServiceQuitParams() : super(kVersions.last.size); | 402 _EchoServiceQuitParams() : super(kVersions.last.size); |
383 | 403 |
| 404 _EchoServiceQuitParams.init( |
| 405 ) : super(kVersions.last.size); |
| 406 |
384 static _EchoServiceQuitParams deserialize(bindings.Message message) { | 407 static _EchoServiceQuitParams deserialize(bindings.Message message) { |
385 var decoder = new bindings.Decoder(message); | 408 var decoder = new bindings.Decoder(message); |
386 var result = decode(decoder); | 409 var result = decode(decoder); |
387 if (decoder.excessHandles != null) { | 410 if (decoder.excessHandles != null) { |
388 decoder.excessHandles.forEach((h) => h.close()); | 411 decoder.excessHandles.forEach((h) => h.close()); |
389 } | 412 } |
390 return result; | 413 return result; |
391 } | 414 } |
392 | 415 |
393 static _EchoServiceQuitParams decode(bindings.Decoder decoder0) { | 416 static _EchoServiceQuitParams decode(bindings.Decoder decoder0) { |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
430 return map; | 453 return map; |
431 } | 454 } |
432 } | 455 } |
433 | 456 |
434 const int _echoServiceMethodEchoStringName = 0; | 457 const int _echoServiceMethodEchoStringName = 0; |
435 const int _echoServiceMethodDelayedEchoStringName = 1; | 458 const int _echoServiceMethodDelayedEchoStringName = 1; |
436 const int _echoServiceMethodSwapName = 2; | 459 const int _echoServiceMethodSwapName = 2; |
437 const int _echoServiceMethodQuitName = 3; | 460 const int _echoServiceMethodQuitName = 3; |
438 | 461 |
439 class _EchoServiceServiceDescription implements service_describer.ServiceDescrip
tion { | 462 class _EchoServiceServiceDescription implements service_describer.ServiceDescrip
tion { |
440 dynamic getTopLevelInterface([Function responseFactory]){ | 463 void getTopLevelInterface(Function responder){ |
441 var interfaceTypeKey = getRuntimeTypeInfo().services["test::EchoService"]; | 464 var interfaceTypeKey = getRuntimeTypeInfo().services["test::EchoService"]; |
442 var userDefinedType = getAllMojomTypeDefinitions()[interfaceTypeKey]; | 465 var userDefinedType = getAllMojomTypeDefinitions()[interfaceTypeKey]; |
443 return responseFactory(userDefinedType.interfaceType); | 466 responder(userDefinedType.interfaceType); |
444 } | 467 } |
445 | 468 |
446 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 469 void getTypeDefinition(String typeKey, Function responder) { |
447 responseFactory(getAllMojomTypeDefinitions()[typeKey]); | 470 responder(getAllMojomTypeDefinitions()[typeKey]); |
| 471 } |
448 | 472 |
449 dynamic getAllTypeDefinitions([Function responseFactory]) => | 473 void getAllTypeDefinitions(Function responder) { |
450 responseFactory(getAllMojomTypeDefinitions()); | 474 responder(getAllMojomTypeDefinitions()); |
| 475 } |
451 } | 476 } |
452 | 477 |
453 abstract class EchoService { | 478 abstract class EchoService { |
454 static const String serviceName = "test::EchoService"; | 479 static const String serviceName = "test::EchoService"; |
455 | 480 |
456 static service_describer.ServiceDescription _cachedServiceDescription; | 481 static service_describer.ServiceDescription _cachedServiceDescription; |
457 static service_describer.ServiceDescription get serviceDescription { | 482 static service_describer.ServiceDescription get serviceDescription { |
458 if (_cachedServiceDescription == null) { | 483 if (_cachedServiceDescription == null) { |
459 _cachedServiceDescription = new _EchoServiceServiceDescription(); | 484 _cachedServiceDescription = new _EchoServiceServiceDescription(); |
460 } | 485 } |
461 return _cachedServiceDescription; | 486 return _cachedServiceDescription; |
462 } | 487 } |
463 | 488 |
464 static EchoServiceProxy connectToService( | 489 static EchoServiceProxy connectToService( |
465 bindings.ServiceConnector s, String url, [String serviceName]) { | 490 bindings.ServiceConnector s, String url, [String serviceName]) { |
466 EchoServiceProxy p = new EchoServiceProxy.unbound(); | 491 EchoServiceProxy p = new EchoServiceProxy.unbound(); |
467 String name = serviceName ?? EchoService.serviceName; | 492 String name = serviceName ?? EchoService.serviceName; |
468 if ((name == null) || name.isEmpty) { | 493 if ((name == null) || name.isEmpty) { |
469 throw new core.MojoApiError( | 494 throw new core.MojoApiError( |
470 "If an interface has no ServiceName, then one must be provided."); | 495 "If an interface has no ServiceName, then one must be provided."); |
471 } | 496 } |
472 s.connectToService(url, p, name); | 497 s.connectToService(url, p, name); |
473 return p; | 498 return p; |
474 } | 499 } |
475 dynamic echoString(String value,[Function responseFactory = null]); | 500 void echoString(String value,void callback(String value)); |
476 dynamic delayedEchoString(String value,int millis,[Function responseFactory =
null]); | 501 void delayedEchoString(String value,int millis,void callback(String value)); |
477 void swap(); | 502 void swap(); |
478 void quit(); | 503 void quit(); |
479 } | 504 } |
480 | 505 |
481 abstract class EchoServiceInterface | 506 abstract class EchoServiceInterface |
482 implements bindings.MojoInterface<EchoService>, | 507 implements bindings.MojoInterface<EchoService>, |
483 EchoService { | 508 EchoService { |
484 factory EchoServiceInterface([EchoService impl]) => | 509 factory EchoServiceInterface([EchoService impl]) => |
485 new EchoServiceStub.unbound(impl); | 510 new EchoServiceStub.unbound(impl); |
486 | 511 |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
518 | 543 |
519 void handleResponse(bindings.ServiceMessage message) { | 544 void handleResponse(bindings.ServiceMessage message) { |
520 switch (message.header.type) { | 545 switch (message.header.type) { |
521 case _echoServiceMethodEchoStringName: | 546 case _echoServiceMethodEchoStringName: |
522 var r = EchoServiceEchoStringResponseParams.deserialize( | 547 var r = EchoServiceEchoStringResponseParams.deserialize( |
523 message.payload); | 548 message.payload); |
524 if (!message.header.hasRequestId) { | 549 if (!message.header.hasRequestId) { |
525 proxyError("Expected a message with a valid request Id."); | 550 proxyError("Expected a message with a valid request Id."); |
526 return; | 551 return; |
527 } | 552 } |
528 Completer c = completerMap[message.header.requestId]; | 553 Function callback = callbackMap[message.header.requestId]; |
529 if (c == null) { | 554 if (callback == null) { |
530 proxyError( | 555 proxyError( |
531 "Message had unknown request Id: ${message.header.requestId}"); | 556 "Message had unknown request Id: ${message.header.requestId}"); |
532 return; | 557 return; |
533 } | 558 } |
534 completerMap.remove(message.header.requestId); | 559 callbackMap.remove(message.header.requestId); |
535 if (c.isCompleted) { | 560 callback(r.value ); |
536 proxyError("Response completer already completed"); | |
537 return; | |
538 } | |
539 c.complete(r); | |
540 break; | 561 break; |
541 case _echoServiceMethodDelayedEchoStringName: | 562 case _echoServiceMethodDelayedEchoStringName: |
542 var r = EchoServiceDelayedEchoStringResponseParams.deserialize( | 563 var r = EchoServiceDelayedEchoStringResponseParams.deserialize( |
543 message.payload); | 564 message.payload); |
544 if (!message.header.hasRequestId) { | 565 if (!message.header.hasRequestId) { |
545 proxyError("Expected a message with a valid request Id."); | 566 proxyError("Expected a message with a valid request Id."); |
546 return; | 567 return; |
547 } | 568 } |
548 Completer c = completerMap[message.header.requestId]; | 569 Function callback = callbackMap[message.header.requestId]; |
549 if (c == null) { | 570 if (callback == null) { |
550 proxyError( | 571 proxyError( |
551 "Message had unknown request Id: ${message.header.requestId}"); | 572 "Message had unknown request Id: ${message.header.requestId}"); |
552 return; | 573 return; |
553 } | 574 } |
554 completerMap.remove(message.header.requestId); | 575 callbackMap.remove(message.header.requestId); |
555 if (c.isCompleted) { | 576 callback(r.value ); |
556 proxyError("Response completer already completed"); | |
557 return; | |
558 } | |
559 c.complete(r); | |
560 break; | 577 break; |
561 default: | 578 default: |
562 proxyError("Unexpected message type: ${message.header.type}"); | 579 proxyError("Unexpected message type: ${message.header.type}"); |
563 close(immediate: true); | 580 close(immediate: true); |
564 break; | 581 break; |
565 } | 582 } |
566 } | 583 } |
567 | 584 |
568 @override | 585 @override |
569 String toString() { | 586 String toString() { |
(...skipping 24 matching lines...) Expand all Loading... |
594 return newMockedProxy; | 611 return newMockedProxy; |
595 } | 612 } |
596 | 613 |
597 static EchoServiceProxy newFromEndpoint( | 614 static EchoServiceProxy newFromEndpoint( |
598 core.MojoMessagePipeEndpoint endpoint) { | 615 core.MojoMessagePipeEndpoint endpoint) { |
599 assert(endpoint.setDescription("For EchoServiceProxy")); | 616 assert(endpoint.setDescription("For EchoServiceProxy")); |
600 return new EchoServiceProxy.fromEndpoint(endpoint); | 617 return new EchoServiceProxy.fromEndpoint(endpoint); |
601 } | 618 } |
602 | 619 |
603 | 620 |
604 dynamic echoString(String value,[Function responseFactory = null]) { | 621 void echoString(String value,void callback(String value)) { |
605 if (impl != null) { | 622 if (impl != null) { |
606 return new Future(() => impl.echoString(value,_EchoServiceStubControl._ech
oServiceEchoStringResponseParamsFactory)); | 623 impl.echoString(value,callback); |
| 624 return; |
607 } | 625 } |
608 var params = new _EchoServiceEchoStringParams(); | 626 var params = new _EchoServiceEchoStringParams(); |
609 params.value = value; | 627 params.value = value; |
610 return ctrl.sendMessageWithRequestId( | 628 ctrl.sendMessageWithRequestId( |
611 params, | 629 params, |
612 _echoServiceMethodEchoStringName, | 630 _echoServiceMethodEchoStringName, |
613 -1, | 631 -1, |
614 bindings.MessageHeader.kMessageExpectsResponse); | 632 bindings.MessageHeader.kMessageExpectsResponse, |
| 633 callback); |
615 } | 634 } |
616 dynamic delayedEchoString(String value,int millis,[Function responseFactory =
null]) { | 635 void delayedEchoString(String value,int millis,void callback(String value)) { |
617 if (impl != null) { | 636 if (impl != null) { |
618 return new Future(() => impl.delayedEchoString(value,millis,_EchoServiceSt
ubControl._echoServiceDelayedEchoStringResponseParamsFactory)); | 637 impl.delayedEchoString(value,millis,callback); |
| 638 return; |
619 } | 639 } |
620 var params = new _EchoServiceDelayedEchoStringParams(); | 640 var params = new _EchoServiceDelayedEchoStringParams(); |
621 params.value = value; | 641 params.value = value; |
622 params.millis = millis; | 642 params.millis = millis; |
623 return ctrl.sendMessageWithRequestId( | 643 ctrl.sendMessageWithRequestId( |
624 params, | 644 params, |
625 _echoServiceMethodDelayedEchoStringName, | 645 _echoServiceMethodDelayedEchoStringName, |
626 -1, | 646 -1, |
627 bindings.MessageHeader.kMessageExpectsResponse); | 647 bindings.MessageHeader.kMessageExpectsResponse, |
| 648 callback); |
628 } | 649 } |
629 void swap() { | 650 void swap() { |
630 if (impl != null) { | 651 if (impl != null) { |
631 impl.swap(); | 652 impl.swap(); |
632 return; | 653 return; |
633 } | 654 } |
634 if (!ctrl.isBound) { | 655 if (!ctrl.isBound) { |
635 ctrl.proxyError("The Proxy is closed."); | 656 ctrl.proxyError("The Proxy is closed."); |
636 return; | 657 return; |
637 } | 658 } |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
669 core.MojoHandle handle, [EchoService impl]) | 690 core.MojoHandle handle, [EchoService impl]) |
670 : super.fromHandle(handle, autoBegin: impl != null) { | 691 : super.fromHandle(handle, autoBegin: impl != null) { |
671 _impl = impl; | 692 _impl = impl; |
672 } | 693 } |
673 | 694 |
674 _EchoServiceStubControl.unbound([this._impl]) : super.unbound(); | 695 _EchoServiceStubControl.unbound([this._impl]) : super.unbound(); |
675 | 696 |
676 String get serviceName => EchoService.serviceName; | 697 String get serviceName => EchoService.serviceName; |
677 | 698 |
678 | 699 |
679 static EchoServiceEchoStringResponseParams _echoServiceEchoStringResponseParam
sFactory(String value) { | 700 Function _echoServiceEchoStringResponseParamsResponder( |
680 var result = new EchoServiceEchoStringResponseParams(); | 701 int requestId) { |
681 result.value = value; | 702 return (String value) { |
682 return result; | 703 var result = new EchoServiceEchoStringResponseParams(); |
| 704 result.value = value; |
| 705 sendResponse(buildResponseWithId( |
| 706 result, |
| 707 _echoServiceMethodEchoStringName, |
| 708 requestId, |
| 709 bindings.MessageHeader.kMessageIsResponse)); |
| 710 }; |
683 } | 711 } |
684 static EchoServiceDelayedEchoStringResponseParams _echoServiceDelayedEchoStrin
gResponseParamsFactory(String value) { | 712 Function _echoServiceDelayedEchoStringResponseParamsResponder( |
685 var result = new EchoServiceDelayedEchoStringResponseParams(); | 713 int requestId) { |
686 result.value = value; | 714 return (String value) { |
687 return result; | 715 var result = new EchoServiceDelayedEchoStringResponseParams(); |
| 716 result.value = value; |
| 717 sendResponse(buildResponseWithId( |
| 718 result, |
| 719 _echoServiceMethodDelayedEchoStringName, |
| 720 requestId, |
| 721 bindings.MessageHeader.kMessageIsResponse)); |
| 722 }; |
688 } | 723 } |
689 | 724 |
690 dynamic handleMessage(bindings.ServiceMessage message) { | 725 void handleMessage(bindings.ServiceMessage message) { |
691 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 726 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
692 return bindings.ControlMessageHandler.handleMessage(this, | 727 bindings.ControlMessageHandler.handleMessage( |
693 0, | 728 this, 0, message); |
694 message); | 729 return; |
695 } | 730 } |
696 if (_impl == null) { | 731 if (_impl == null) { |
697 throw new core.MojoApiError("$this has no implementation set"); | 732 throw new core.MojoApiError("$this has no implementation set"); |
698 } | 733 } |
699 switch (message.header.type) { | 734 switch (message.header.type) { |
700 case _echoServiceMethodEchoStringName: | 735 case _echoServiceMethodEchoStringName: |
701 var params = _EchoServiceEchoStringParams.deserialize( | 736 var params = _EchoServiceEchoStringParams.deserialize( |
702 message.payload); | 737 message.payload); |
703 var response = _impl.echoString(params.value,_echoServiceEchoStringRespo
nseParamsFactory); | 738 _impl.echoString(params.value, _echoServiceEchoStringResponseParamsRespo
nder(message.header.requestId)); |
704 if (response is Future) { | |
705 return response.then((response) { | |
706 if (response != null) { | |
707 return buildResponseWithId( | |
708 response, | |
709 _echoServiceMethodEchoStringName, | |
710 message.header.requestId, | |
711 bindings.MessageHeader.kMessageIsResponse); | |
712 } | |
713 }); | |
714 } else if (response != null) { | |
715 return buildResponseWithId( | |
716 response, | |
717 _echoServiceMethodEchoStringName, | |
718 message.header.requestId, | |
719 bindings.MessageHeader.kMessageIsResponse); | |
720 } | |
721 break; | 739 break; |
722 case _echoServiceMethodDelayedEchoStringName: | 740 case _echoServiceMethodDelayedEchoStringName: |
723 var params = _EchoServiceDelayedEchoStringParams.deserialize( | 741 var params = _EchoServiceDelayedEchoStringParams.deserialize( |
724 message.payload); | 742 message.payload); |
725 var response = _impl.delayedEchoString(params.value,params.millis,_echoS
erviceDelayedEchoStringResponseParamsFactory); | 743 _impl.delayedEchoString(params.value, params.millis, _echoServiceDelayed
EchoStringResponseParamsResponder(message.header.requestId)); |
726 if (response is Future) { | |
727 return response.then((response) { | |
728 if (response != null) { | |
729 return buildResponseWithId( | |
730 response, | |
731 _echoServiceMethodDelayedEchoStringName, | |
732 message.header.requestId, | |
733 bindings.MessageHeader.kMessageIsResponse); | |
734 } | |
735 }); | |
736 } else if (response != null) { | |
737 return buildResponseWithId( | |
738 response, | |
739 _echoServiceMethodDelayedEchoStringName, | |
740 message.header.requestId, | |
741 bindings.MessageHeader.kMessageIsResponse); | |
742 } | |
743 break; | 744 break; |
744 case _echoServiceMethodSwapName: | 745 case _echoServiceMethodSwapName: |
745 _impl.swap(); | 746 _impl.swap(); |
746 break; | 747 break; |
747 case _echoServiceMethodQuitName: | 748 case _echoServiceMethodQuitName: |
748 _impl.quit(); | 749 _impl.quit(); |
749 break; | 750 break; |
750 default: | 751 default: |
751 throw new bindings.MojoCodecError("Unexpected message name"); | 752 throw new bindings.MojoCodecError("Unexpected message name"); |
752 break; | 753 break; |
753 } | 754 } |
754 return null; | |
755 } | 755 } |
756 | 756 |
757 EchoService get impl => _impl; | 757 EchoService get impl => _impl; |
758 set impl(EchoService d) { | 758 set impl(EchoService d) { |
759 if (d == null) { | 759 if (d == null) { |
760 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 760 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
761 } | 761 } |
762 if (isBound && (_impl == null)) { | 762 if (isBound && (_impl == null)) { |
763 beginHandlingEvents(); | 763 beginHandlingEvents(); |
764 } | 764 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
798 core.MojoHandle handle, [EchoService impl]) | 798 core.MojoHandle handle, [EchoService impl]) |
799 : super(new _EchoServiceStubControl.fromHandle(handle, impl)); | 799 : super(new _EchoServiceStubControl.fromHandle(handle, impl)); |
800 | 800 |
801 static EchoServiceStub newFromEndpoint( | 801 static EchoServiceStub newFromEndpoint( |
802 core.MojoMessagePipeEndpoint endpoint) { | 802 core.MojoMessagePipeEndpoint endpoint) { |
803 assert(endpoint.setDescription("For EchoServiceStub")); | 803 assert(endpoint.setDescription("For EchoServiceStub")); |
804 return new EchoServiceStub.fromEndpoint(endpoint); | 804 return new EchoServiceStub.fromEndpoint(endpoint); |
805 } | 805 } |
806 | 806 |
807 | 807 |
808 dynamic echoString(String value,[Function responseFactory = null]) { | 808 void echoString(String value,void callback(String value)) { |
809 return impl.echoString(value,responseFactory); | 809 return impl.echoString(value,callback); |
810 } | 810 } |
811 dynamic delayedEchoString(String value,int millis,[Function responseFactory =
null]) { | 811 void delayedEchoString(String value,int millis,void callback(String value)) { |
812 return impl.delayedEchoString(value,millis,responseFactory); | 812 return impl.delayedEchoString(value,millis,callback); |
813 } | 813 } |
814 void swap() { | 814 void swap() { |
815 return impl.swap(); | 815 return impl.swap(); |
816 } | 816 } |
817 void quit() { | 817 void quit() { |
818 return impl.quit(); | 818 return impl.quit(); |
819 } | 819 } |
820 } | 820 } |
821 | 821 |
822 | 822 |
823 mojom_types.RuntimeTypeInfo getRuntimeTypeInfo() => _runtimeTypeInfo ?? | 823 mojom_types.RuntimeTypeInfo getRuntimeTypeInfo() => _runtimeTypeInfo ?? |
824 _initRuntimeTypeInfo(); | 824 _initRuntimeTypeInfo(); |
825 | 825 |
826 Map<String, mojom_types.UserDefinedType> getAllMojomTypeDefinitions() { | 826 Map<String, mojom_types.UserDefinedType> getAllMojomTypeDefinitions() { |
827 return getRuntimeTypeInfo().typeMap; | 827 return getRuntimeTypeInfo().typeMap; |
828 } | 828 } |
829 | 829 |
830 var _runtimeTypeInfo; | 830 var _runtimeTypeInfo; |
831 mojom_types.RuntimeTypeInfo _initRuntimeTypeInfo() { | 831 mojom_types.RuntimeTypeInfo _initRuntimeTypeInfo() { |
832 // serializedRuntimeTypeInfo contains the bytes of the Mojo serialization of | 832 // serializedRuntimeTypeInfo contains the bytes of the Mojo serialization of |
833 // a mojom_types.RuntimeTypeInfo struct describing the Mojom types in this | 833 // a mojom_types.RuntimeTypeInfo struct describing the Mojom types in this |
834 // file. The string contains the base64 encoding of the gzip-compressed bytes. | 834 // file. The string contains the base64 encoding of the gzip-compressed bytes. |
835 var serializedRuntimeTypeInfo = "H4sIAAAJbogC/+xYS28TMRDeR4HQBlReUngcAqdwoOZYR
ULKgUiVkFBRuVQcolViyKLsA3u3iBtHfgJHjhz5ST1y5B+AzY7BmdiRFzUsQRlpOvE2s/b3+ZvxbjpeZ
bsQP0DE1/e1sS+8BeObwq8ILygv+v3heJodUXYSj6nl+3ch5/nx4XD0ZHjcl4l7i3l4/sEZ3M+H/FDL7
0HsQpz6VXwP0UPzKx4+QvwM8TvYF89seN1dA84L2vVrwneEA4qnUUKd+FZ5+D8dmAPTg3mW69sW/kLOL
ZxMs4QSVk6yJE4pI0n2OiOcjasPk4gVJMpzeVdO5N+RGHESpwVlL6Mx5YSKuUa8mmxPJiVOOPC6dL624
LPkM4D97MF19b1P56p40K7i4WXzfn9VOgjN+63sIRrLvTZdV3YVePyJrGBx+sqM6yJgWDXfWG8Kdytwx
ytt34L3FmD+jfcBo29KsUIzbmWrxo3rbmDpZ988N3PVRc+Sf0m4lOZJNCupRQ83/hIvqoZMPHW0NfuWO
lyFjm5DD5vTEc+zlNONjmrqqPcP6wj3YcXbwdb8/Vx48rV9wKbOmcd0Fr2jE9yOF3jbbqgfK/zdsF4dD
Sy41XPRAu75ttxYPXWA5199xV+PupL6uNNAXZl48WCtJmv9AS/+El7k49N54Uk8m8XczMv9Bvqw3l8Cb
Wyrr93gbOrrHjzzmOpLO64251WNunq0RufVKcIX1OApWMJTG95jjt5GuUk/Ow2dT6coutaP7f3oOmCVO
PUjqal6aTnowVvyuwHWQ1iDp9BBD8/K2MhP+z/Tg8S5jnr4EQAA//+qos9XSBMAAA=="; | 835 var serializedRuntimeTypeInfo = "H4sIAAAJbogC/+xYvY4TMRDenwPCXUD8SstPEahCwRlRR
ZGQUpAKCYGO5qrI2jPJot3sst4cgifgESgpKSl5BB7lSko6sC9jcCZ2cKIjq5xupLmJfZnY3+dvxptE3
tSuQPwIEc93tLEvvAHjW8KvCq8Yr7rdfjzK91h5mMTM8v57kPNq/0V/8Ky/35WJu/N5eP3eCXyeD/mhl
t+G2IJY+MADRA+tr3j4BPELxF9gXz2z4X23DDgvaPPXhe8IBxTPacac+FZ5+D8RrIHpwTzL/W0LHwofC
CcTXpI0j2lKhnk+TBkZ5RkjH0pKsvxN/pjwMj5+RQ5oWRFaFHIFTuTfgRhxkowrVr6mMeOEiXUHfLrwr
kzK/okH70/nbQteS14DONc2zKv3fT83jZ+b0/jtsvncf6hzDs3nruwRGsszN80ruwZ8HiOrymQ8NOO6C
BjWxTvWn8IfBe64pXUsuG8D9r+4H5bs7UTszoxf2brw43rsWfrcT8/NXHXStuRfEi6lekjTCbPo4+aa+
VG1ZepfkbZ331Kf/0NXd6DHzeiKF/mYszNdrair9gboCvdrxd9oa/bzXPjytfPApu6jpyyl79kBbttz/
G3X3LcVD51wufrqWfCr56k5/LPtu/Y6i4D3P/rwN6PepF7u1lhvJn482LPJGivw4y/gRz5+nReeJWmac
DM/D2rs13r/CbSxre5awcnU3X14ZjLVnXa9nd1vK9Tbkw28344QzmAJvoIFfDXh+9HeO1qY9LRT8312h
KJrXdm+f90AzBKvfoXVXUcNB314C36nwPoIl+ArdNDHy0li5Kl5SvUh8W6yPn4HAAD//6kk0hzIEwAA"
; |
836 | 836 |
837 // Deserialize RuntimeTypeInfo | 837 // Deserialize RuntimeTypeInfo |
838 var bytes = BASE64.decode(serializedRuntimeTypeInfo); | 838 var bytes = BASE64.decode(serializedRuntimeTypeInfo); |
839 var unzippedBytes = new ZLibDecoder().convert(bytes); | 839 var unzippedBytes = new ZLibDecoder().convert(bytes); |
840 var bdata = new ByteData.view(unzippedBytes.buffer); | 840 var bdata = new ByteData.view(unzippedBytes.buffer); |
841 var message = new bindings.Message(bdata, null, unzippedBytes.length, 0); | 841 var message = new bindings.Message(bdata, null, unzippedBytes.length, 0); |
842 _runtimeTypeInfo = mojom_types.RuntimeTypeInfo.deserialize(message); | 842 _runtimeTypeInfo = mojom_types.RuntimeTypeInfo.deserialize(message); |
843 return _runtimeTypeInfo; | 843 return _runtimeTypeInfo; |
844 } | 844 } |
OLD | NEW |