OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 library contacts_mojom; | 5 library contacts_mojom; |
6 import 'dart:async'; | 6 import 'dart:async'; |
7 import 'package:mojo/bindings.dart' as bindings; | 7 import 'package:mojo/bindings.dart' as bindings; |
8 import 'package:mojo/core.dart' as core; | 8 import 'package:mojo/core.dart' as core; |
9 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; | 9 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; |
10 | 10 |
11 | 11 |
12 | 12 |
13 class Contact extends bindings.Struct { | 13 class Contact extends bindings.Struct { |
14 static const List<bindings.StructDataHeader> kVersions = const [ | 14 static const List<bindings.StructDataHeader> kVersions = const [ |
15 const bindings.StructDataHeader(24, 0) | 15 const bindings.StructDataHeader(24, 0) |
16 ]; | 16 ]; |
17 int id = 0; | 17 int id = 0; |
18 String name = null; | 18 String name = null; |
19 | 19 |
20 Contact() : super(kVersions.last.size); | 20 Contact() : super(kVersions.last.size); |
21 | 21 |
| 22 Contact.init( |
| 23 int this.id, |
| 24 String this.name |
| 25 ) : super(kVersions.last.size); |
| 26 |
22 static Contact deserialize(bindings.Message message) { | 27 static Contact deserialize(bindings.Message message) { |
23 var decoder = new bindings.Decoder(message); | 28 var decoder = new bindings.Decoder(message); |
24 var result = decode(decoder); | 29 var result = decode(decoder); |
25 if (decoder.excessHandles != null) { | 30 if (decoder.excessHandles != null) { |
26 decoder.excessHandles.forEach((h) => h.close()); | 31 decoder.excessHandles.forEach((h) => h.close()); |
27 } | 32 } |
28 return result; | 33 return result; |
29 } | 34 } |
30 | 35 |
31 static Contact decode(bindings.Decoder decoder0) { | 36 static Contact decode(bindings.Decoder decoder0) { |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
97 | 102 |
98 | 103 |
99 class _ContactsServiceGetCountParams extends bindings.Struct { | 104 class _ContactsServiceGetCountParams extends bindings.Struct { |
100 static const List<bindings.StructDataHeader> kVersions = const [ | 105 static const List<bindings.StructDataHeader> kVersions = const [ |
101 const bindings.StructDataHeader(16, 0) | 106 const bindings.StructDataHeader(16, 0) |
102 ]; | 107 ]; |
103 String filter = null; | 108 String filter = null; |
104 | 109 |
105 _ContactsServiceGetCountParams() : super(kVersions.last.size); | 110 _ContactsServiceGetCountParams() : super(kVersions.last.size); |
106 | 111 |
| 112 _ContactsServiceGetCountParams.init( |
| 113 String this.filter |
| 114 ) : super(kVersions.last.size); |
| 115 |
107 static _ContactsServiceGetCountParams deserialize(bindings.Message message) { | 116 static _ContactsServiceGetCountParams deserialize(bindings.Message message) { |
108 var decoder = new bindings.Decoder(message); | 117 var decoder = new bindings.Decoder(message); |
109 var result = decode(decoder); | 118 var result = decode(decoder); |
110 if (decoder.excessHandles != null) { | 119 if (decoder.excessHandles != null) { |
111 decoder.excessHandles.forEach((h) => h.close()); | 120 decoder.excessHandles.forEach((h) => h.close()); |
112 } | 121 } |
113 return result; | 122 return result; |
114 } | 123 } |
115 | 124 |
116 static _ContactsServiceGetCountParams decode(bindings.Decoder decoder0) { | 125 static _ContactsServiceGetCountParams decode(bindings.Decoder decoder0) { |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
169 | 178 |
170 | 179 |
171 class ContactsServiceGetCountResponseParams extends bindings.Struct { | 180 class ContactsServiceGetCountResponseParams extends bindings.Struct { |
172 static const List<bindings.StructDataHeader> kVersions = const [ | 181 static const List<bindings.StructDataHeader> kVersions = const [ |
173 const bindings.StructDataHeader(16, 0) | 182 const bindings.StructDataHeader(16, 0) |
174 ]; | 183 ]; |
175 int count = 0; | 184 int count = 0; |
176 | 185 |
177 ContactsServiceGetCountResponseParams() : super(kVersions.last.size); | 186 ContactsServiceGetCountResponseParams() : super(kVersions.last.size); |
178 | 187 |
| 188 ContactsServiceGetCountResponseParams.init( |
| 189 int this.count |
| 190 ) : super(kVersions.last.size); |
| 191 |
179 static ContactsServiceGetCountResponseParams deserialize(bindings.Message mess
age) { | 192 static ContactsServiceGetCountResponseParams deserialize(bindings.Message mess
age) { |
180 var decoder = new bindings.Decoder(message); | 193 var decoder = new bindings.Decoder(message); |
181 var result = decode(decoder); | 194 var result = decode(decoder); |
182 if (decoder.excessHandles != null) { | 195 if (decoder.excessHandles != null) { |
183 decoder.excessHandles.forEach((h) => h.close()); | 196 decoder.excessHandles.forEach((h) => h.close()); |
184 } | 197 } |
185 return result; | 198 return result; |
186 } | 199 } |
187 | 200 |
188 static ContactsServiceGetCountResponseParams decode(bindings.Decoder decoder0)
{ | 201 static ContactsServiceGetCountResponseParams decode(bindings.Decoder decoder0)
{ |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
243 class _ContactsServiceGetParams extends bindings.Struct { | 256 class _ContactsServiceGetParams extends bindings.Struct { |
244 static const List<bindings.StructDataHeader> kVersions = const [ | 257 static const List<bindings.StructDataHeader> kVersions = const [ |
245 const bindings.StructDataHeader(24, 0) | 258 const bindings.StructDataHeader(24, 0) |
246 ]; | 259 ]; |
247 String filter = null; | 260 String filter = null; |
248 int offset = 0; | 261 int offset = 0; |
249 int limit = 0; | 262 int limit = 0; |
250 | 263 |
251 _ContactsServiceGetParams() : super(kVersions.last.size); | 264 _ContactsServiceGetParams() : super(kVersions.last.size); |
252 | 265 |
| 266 _ContactsServiceGetParams.init( |
| 267 String this.filter, |
| 268 int this.offset, |
| 269 int this.limit |
| 270 ) : super(kVersions.last.size); |
| 271 |
253 static _ContactsServiceGetParams deserialize(bindings.Message message) { | 272 static _ContactsServiceGetParams deserialize(bindings.Message message) { |
254 var decoder = new bindings.Decoder(message); | 273 var decoder = new bindings.Decoder(message); |
255 var result = decode(decoder); | 274 var result = decode(decoder); |
256 if (decoder.excessHandles != null) { | 275 if (decoder.excessHandles != null) { |
257 decoder.excessHandles.forEach((h) => h.close()); | 276 decoder.excessHandles.forEach((h) => h.close()); |
258 } | 277 } |
259 return result; | 278 return result; |
260 } | 279 } |
261 | 280 |
262 static _ContactsServiceGetParams decode(bindings.Decoder decoder0) { | 281 static _ContactsServiceGetParams decode(bindings.Decoder decoder0) { |
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
341 | 360 |
342 | 361 |
343 class ContactsServiceGetResponseParams extends bindings.Struct { | 362 class ContactsServiceGetResponseParams extends bindings.Struct { |
344 static const List<bindings.StructDataHeader> kVersions = const [ | 363 static const List<bindings.StructDataHeader> kVersions = const [ |
345 const bindings.StructDataHeader(16, 0) | 364 const bindings.StructDataHeader(16, 0) |
346 ]; | 365 ]; |
347 List<Contact> contacts = null; | 366 List<Contact> contacts = null; |
348 | 367 |
349 ContactsServiceGetResponseParams() : super(kVersions.last.size); | 368 ContactsServiceGetResponseParams() : super(kVersions.last.size); |
350 | 369 |
| 370 ContactsServiceGetResponseParams.init( |
| 371 List<Contact> this.contacts |
| 372 ) : super(kVersions.last.size); |
| 373 |
351 static ContactsServiceGetResponseParams deserialize(bindings.Message message)
{ | 374 static ContactsServiceGetResponseParams deserialize(bindings.Message message)
{ |
352 var decoder = new bindings.Decoder(message); | 375 var decoder = new bindings.Decoder(message); |
353 var result = decode(decoder); | 376 var result = decode(decoder); |
354 if (decoder.excessHandles != null) { | 377 if (decoder.excessHandles != null) { |
355 decoder.excessHandles.forEach((h) => h.close()); | 378 decoder.excessHandles.forEach((h) => h.close()); |
356 } | 379 } |
357 return result; | 380 return result; |
358 } | 381 } |
359 | 382 |
360 static ContactsServiceGetResponseParams decode(bindings.Decoder decoder0) { | 383 static ContactsServiceGetResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
429 | 452 |
430 | 453 |
431 class _ContactsServiceGetEmailsParams extends bindings.Struct { | 454 class _ContactsServiceGetEmailsParams extends bindings.Struct { |
432 static const List<bindings.StructDataHeader> kVersions = const [ | 455 static const List<bindings.StructDataHeader> kVersions = const [ |
433 const bindings.StructDataHeader(16, 0) | 456 const bindings.StructDataHeader(16, 0) |
434 ]; | 457 ]; |
435 int id = 0; | 458 int id = 0; |
436 | 459 |
437 _ContactsServiceGetEmailsParams() : super(kVersions.last.size); | 460 _ContactsServiceGetEmailsParams() : super(kVersions.last.size); |
438 | 461 |
| 462 _ContactsServiceGetEmailsParams.init( |
| 463 int this.id |
| 464 ) : super(kVersions.last.size); |
| 465 |
439 static _ContactsServiceGetEmailsParams deserialize(bindings.Message message) { | 466 static _ContactsServiceGetEmailsParams deserialize(bindings.Message message) { |
440 var decoder = new bindings.Decoder(message); | 467 var decoder = new bindings.Decoder(message); |
441 var result = decode(decoder); | 468 var result = decode(decoder); |
442 if (decoder.excessHandles != null) { | 469 if (decoder.excessHandles != null) { |
443 decoder.excessHandles.forEach((h) => h.close()); | 470 decoder.excessHandles.forEach((h) => h.close()); |
444 } | 471 } |
445 return result; | 472 return result; |
446 } | 473 } |
447 | 474 |
448 static _ContactsServiceGetEmailsParams decode(bindings.Decoder decoder0) { | 475 static _ContactsServiceGetEmailsParams decode(bindings.Decoder decoder0) { |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
501 | 528 |
502 | 529 |
503 class ContactsServiceGetEmailsResponseParams extends bindings.Struct { | 530 class ContactsServiceGetEmailsResponseParams extends bindings.Struct { |
504 static const List<bindings.StructDataHeader> kVersions = const [ | 531 static const List<bindings.StructDataHeader> kVersions = const [ |
505 const bindings.StructDataHeader(16, 0) | 532 const bindings.StructDataHeader(16, 0) |
506 ]; | 533 ]; |
507 List<String> emails = null; | 534 List<String> emails = null; |
508 | 535 |
509 ContactsServiceGetEmailsResponseParams() : super(kVersions.last.size); | 536 ContactsServiceGetEmailsResponseParams() : super(kVersions.last.size); |
510 | 537 |
| 538 ContactsServiceGetEmailsResponseParams.init( |
| 539 List<String> this.emails |
| 540 ) : super(kVersions.last.size); |
| 541 |
511 static ContactsServiceGetEmailsResponseParams deserialize(bindings.Message mes
sage) { | 542 static ContactsServiceGetEmailsResponseParams deserialize(bindings.Message mes
sage) { |
512 var decoder = new bindings.Decoder(message); | 543 var decoder = new bindings.Decoder(message); |
513 var result = decode(decoder); | 544 var result = decode(decoder); |
514 if (decoder.excessHandles != null) { | 545 if (decoder.excessHandles != null) { |
515 decoder.excessHandles.forEach((h) => h.close()); | 546 decoder.excessHandles.forEach((h) => h.close()); |
516 } | 547 } |
517 return result; | 548 return result; |
518 } | 549 } |
519 | 550 |
520 static ContactsServiceGetEmailsResponseParams decode(bindings.Decoder decoder0
) { | 551 static ContactsServiceGetEmailsResponseParams decode(bindings.Decoder decoder0
) { |
(...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
589 | 620 |
590 class _ContactsServiceGetPhotoParams extends bindings.Struct { | 621 class _ContactsServiceGetPhotoParams extends bindings.Struct { |
591 static const List<bindings.StructDataHeader> kVersions = const [ | 622 static const List<bindings.StructDataHeader> kVersions = const [ |
592 const bindings.StructDataHeader(24, 0) | 623 const bindings.StructDataHeader(24, 0) |
593 ]; | 624 ]; |
594 int id = 0; | 625 int id = 0; |
595 bool highResolution = false; | 626 bool highResolution = false; |
596 | 627 |
597 _ContactsServiceGetPhotoParams() : super(kVersions.last.size); | 628 _ContactsServiceGetPhotoParams() : super(kVersions.last.size); |
598 | 629 |
| 630 _ContactsServiceGetPhotoParams.init( |
| 631 int this.id, |
| 632 bool this.highResolution |
| 633 ) : super(kVersions.last.size); |
| 634 |
599 static _ContactsServiceGetPhotoParams deserialize(bindings.Message message) { | 635 static _ContactsServiceGetPhotoParams deserialize(bindings.Message message) { |
600 var decoder = new bindings.Decoder(message); | 636 var decoder = new bindings.Decoder(message); |
601 var result = decode(decoder); | 637 var result = decode(decoder); |
602 if (decoder.excessHandles != null) { | 638 if (decoder.excessHandles != null) { |
603 decoder.excessHandles.forEach((h) => h.close()); | 639 decoder.excessHandles.forEach((h) => h.close()); |
604 } | 640 } |
605 return result; | 641 return result; |
606 } | 642 } |
607 | 643 |
608 static _ContactsServiceGetPhotoParams decode(bindings.Decoder decoder0) { | 644 static _ContactsServiceGetPhotoParams decode(bindings.Decoder decoder0) { |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
674 | 710 |
675 | 711 |
676 class ContactsServiceGetPhotoResponseParams extends bindings.Struct { | 712 class ContactsServiceGetPhotoResponseParams extends bindings.Struct { |
677 static const List<bindings.StructDataHeader> kVersions = const [ | 713 static const List<bindings.StructDataHeader> kVersions = const [ |
678 const bindings.StructDataHeader(16, 0) | 714 const bindings.StructDataHeader(16, 0) |
679 ]; | 715 ]; |
680 String photoUrl = null; | 716 String photoUrl = null; |
681 | 717 |
682 ContactsServiceGetPhotoResponseParams() : super(kVersions.last.size); | 718 ContactsServiceGetPhotoResponseParams() : super(kVersions.last.size); |
683 | 719 |
| 720 ContactsServiceGetPhotoResponseParams.init( |
| 721 String this.photoUrl |
| 722 ) : super(kVersions.last.size); |
| 723 |
684 static ContactsServiceGetPhotoResponseParams deserialize(bindings.Message mess
age) { | 724 static ContactsServiceGetPhotoResponseParams deserialize(bindings.Message mess
age) { |
685 var decoder = new bindings.Decoder(message); | 725 var decoder = new bindings.Decoder(message); |
686 var result = decode(decoder); | 726 var result = decode(decoder); |
687 if (decoder.excessHandles != null) { | 727 if (decoder.excessHandles != null) { |
688 decoder.excessHandles.forEach((h) => h.close()); | 728 decoder.excessHandles.forEach((h) => h.close()); |
689 } | 729 } |
690 return result; | 730 return result; |
691 } | 731 } |
692 | 732 |
693 static ContactsServiceGetPhotoResponseParams decode(bindings.Decoder decoder0)
{ | 733 static ContactsServiceGetPhotoResponseParams decode(bindings.Decoder decoder0)
{ |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
743 return map; | 783 return map; |
744 } | 784 } |
745 } | 785 } |
746 | 786 |
747 const int _contactsServiceMethodGetCountName = 0; | 787 const int _contactsServiceMethodGetCountName = 0; |
748 const int _contactsServiceMethodGetName = 1; | 788 const int _contactsServiceMethodGetName = 1; |
749 const int _contactsServiceMethodGetEmailsName = 2; | 789 const int _contactsServiceMethodGetEmailsName = 2; |
750 const int _contactsServiceMethodGetPhotoName = 3; | 790 const int _contactsServiceMethodGetPhotoName = 3; |
751 | 791 |
752 class _ContactsServiceServiceDescription implements service_describer.ServiceDes
cription { | 792 class _ContactsServiceServiceDescription implements service_describer.ServiceDes
cription { |
753 dynamic getTopLevelInterface([Function responseFactory]) => | 793 void getTopLevelInterface(Function responder) { |
754 responseFactory(null); | 794 responder(null); |
| 795 } |
755 | 796 |
756 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 797 void getTypeDefinition(String typeKey, Function responder) { |
757 responseFactory(null); | 798 responder(null); |
| 799 } |
758 | 800 |
759 dynamic getAllTypeDefinitions([Function responseFactory]) => | 801 void getAllTypeDefinitions(Function responder) { |
760 responseFactory(null); | 802 responder(null); |
| 803 } |
761 } | 804 } |
762 | 805 |
763 abstract class ContactsService { | 806 abstract class ContactsService { |
764 static const String serviceName = "contacts::ContactsService"; | 807 static const String serviceName = "contacts::ContactsService"; |
765 | 808 |
766 static service_describer.ServiceDescription _cachedServiceDescription; | 809 static service_describer.ServiceDescription _cachedServiceDescription; |
767 static service_describer.ServiceDescription get serviceDescription { | 810 static service_describer.ServiceDescription get serviceDescription { |
768 if (_cachedServiceDescription == null) { | 811 if (_cachedServiceDescription == null) { |
769 _cachedServiceDescription = new _ContactsServiceServiceDescription(); | 812 _cachedServiceDescription = new _ContactsServiceServiceDescription(); |
770 } | 813 } |
771 return _cachedServiceDescription; | 814 return _cachedServiceDescription; |
772 } | 815 } |
773 | 816 |
774 static ContactsServiceProxy connectToService( | 817 static ContactsServiceProxy connectToService( |
775 bindings.ServiceConnector s, String url, [String serviceName]) { | 818 bindings.ServiceConnector s, String url, [String serviceName]) { |
776 ContactsServiceProxy p = new ContactsServiceProxy.unbound(); | 819 ContactsServiceProxy p = new ContactsServiceProxy.unbound(); |
777 String name = serviceName ?? ContactsService.serviceName; | 820 String name = serviceName ?? ContactsService.serviceName; |
778 if ((name == null) || name.isEmpty) { | 821 if ((name == null) || name.isEmpty) { |
779 throw new core.MojoApiError( | 822 throw new core.MojoApiError( |
780 "If an interface has no ServiceName, then one must be provided."); | 823 "If an interface has no ServiceName, then one must be provided."); |
781 } | 824 } |
782 s.connectToService(url, p, name); | 825 s.connectToService(url, p, name); |
783 return p; | 826 return p; |
784 } | 827 } |
785 dynamic getCount(String filter,[Function responseFactory = null]); | 828 void getCount(String filter,void callback(int count)); |
786 dynamic get(String filter,int offset,int limit,[Function responseFactory = nul
l]); | 829 void get(String filter,int offset,int limit,void callback(List<Contact> contac
ts)); |
787 dynamic getEmails(int id,[Function responseFactory = null]); | 830 void getEmails(int id,void callback(List<String> emails)); |
788 dynamic getPhoto(int id,bool highResolution,[Function responseFactory = null])
; | 831 void getPhoto(int id,bool highResolution,void callback(String photoUrl)); |
789 } | 832 } |
790 | 833 |
791 abstract class ContactsServiceInterface | 834 abstract class ContactsServiceInterface |
792 implements bindings.MojoInterface<ContactsService>, | 835 implements bindings.MojoInterface<ContactsService>, |
793 ContactsService { | 836 ContactsService { |
794 factory ContactsServiceInterface([ContactsService impl]) => | 837 factory ContactsServiceInterface([ContactsService impl]) => |
795 new ContactsServiceStub.unbound(impl); | 838 new ContactsServiceStub.unbound(impl); |
796 | 839 |
797 factory ContactsServiceInterface.fromEndpoint( | 840 factory ContactsServiceInterface.fromEndpoint( |
798 core.MojoMessagePipeEndpoint endpoint, | 841 core.MojoMessagePipeEndpoint endpoint, |
(...skipping 29 matching lines...) Expand all Loading... |
828 | 871 |
829 void handleResponse(bindings.ServiceMessage message) { | 872 void handleResponse(bindings.ServiceMessage message) { |
830 switch (message.header.type) { | 873 switch (message.header.type) { |
831 case _contactsServiceMethodGetCountName: | 874 case _contactsServiceMethodGetCountName: |
832 var r = ContactsServiceGetCountResponseParams.deserialize( | 875 var r = ContactsServiceGetCountResponseParams.deserialize( |
833 message.payload); | 876 message.payload); |
834 if (!message.header.hasRequestId) { | 877 if (!message.header.hasRequestId) { |
835 proxyError("Expected a message with a valid request Id."); | 878 proxyError("Expected a message with a valid request Id."); |
836 return; | 879 return; |
837 } | 880 } |
838 Completer c = completerMap[message.header.requestId]; | 881 Function callback = callbackMap[message.header.requestId]; |
839 if (c == null) { | 882 if (callback == null) { |
840 proxyError( | 883 proxyError( |
841 "Message had unknown request Id: ${message.header.requestId}"); | 884 "Message had unknown request Id: ${message.header.requestId}"); |
842 return; | 885 return; |
843 } | 886 } |
844 completerMap.remove(message.header.requestId); | 887 callbackMap.remove(message.header.requestId); |
845 if (c.isCompleted) { | 888 callback(r.count ); |
846 proxyError("Response completer already completed"); | |
847 return; | |
848 } | |
849 c.complete(r); | |
850 break; | 889 break; |
851 case _contactsServiceMethodGetName: | 890 case _contactsServiceMethodGetName: |
852 var r = ContactsServiceGetResponseParams.deserialize( | 891 var r = ContactsServiceGetResponseParams.deserialize( |
853 message.payload); | 892 message.payload); |
854 if (!message.header.hasRequestId) { | 893 if (!message.header.hasRequestId) { |
855 proxyError("Expected a message with a valid request Id."); | 894 proxyError("Expected a message with a valid request Id."); |
856 return; | 895 return; |
857 } | 896 } |
858 Completer c = completerMap[message.header.requestId]; | 897 Function callback = callbackMap[message.header.requestId]; |
859 if (c == null) { | 898 if (callback == null) { |
860 proxyError( | 899 proxyError( |
861 "Message had unknown request Id: ${message.header.requestId}"); | 900 "Message had unknown request Id: ${message.header.requestId}"); |
862 return; | 901 return; |
863 } | 902 } |
864 completerMap.remove(message.header.requestId); | 903 callbackMap.remove(message.header.requestId); |
865 if (c.isCompleted) { | 904 callback(r.contacts ); |
866 proxyError("Response completer already completed"); | |
867 return; | |
868 } | |
869 c.complete(r); | |
870 break; | 905 break; |
871 case _contactsServiceMethodGetEmailsName: | 906 case _contactsServiceMethodGetEmailsName: |
872 var r = ContactsServiceGetEmailsResponseParams.deserialize( | 907 var r = ContactsServiceGetEmailsResponseParams.deserialize( |
873 message.payload); | 908 message.payload); |
874 if (!message.header.hasRequestId) { | 909 if (!message.header.hasRequestId) { |
875 proxyError("Expected a message with a valid request Id."); | 910 proxyError("Expected a message with a valid request Id."); |
876 return; | 911 return; |
877 } | 912 } |
878 Completer c = completerMap[message.header.requestId]; | 913 Function callback = callbackMap[message.header.requestId]; |
879 if (c == null) { | 914 if (callback == null) { |
880 proxyError( | 915 proxyError( |
881 "Message had unknown request Id: ${message.header.requestId}"); | 916 "Message had unknown request Id: ${message.header.requestId}"); |
882 return; | 917 return; |
883 } | 918 } |
884 completerMap.remove(message.header.requestId); | 919 callbackMap.remove(message.header.requestId); |
885 if (c.isCompleted) { | 920 callback(r.emails ); |
886 proxyError("Response completer already completed"); | |
887 return; | |
888 } | |
889 c.complete(r); | |
890 break; | 921 break; |
891 case _contactsServiceMethodGetPhotoName: | 922 case _contactsServiceMethodGetPhotoName: |
892 var r = ContactsServiceGetPhotoResponseParams.deserialize( | 923 var r = ContactsServiceGetPhotoResponseParams.deserialize( |
893 message.payload); | 924 message.payload); |
894 if (!message.header.hasRequestId) { | 925 if (!message.header.hasRequestId) { |
895 proxyError("Expected a message with a valid request Id."); | 926 proxyError("Expected a message with a valid request Id."); |
896 return; | 927 return; |
897 } | 928 } |
898 Completer c = completerMap[message.header.requestId]; | 929 Function callback = callbackMap[message.header.requestId]; |
899 if (c == null) { | 930 if (callback == null) { |
900 proxyError( | 931 proxyError( |
901 "Message had unknown request Id: ${message.header.requestId}"); | 932 "Message had unknown request Id: ${message.header.requestId}"); |
902 return; | 933 return; |
903 } | 934 } |
904 completerMap.remove(message.header.requestId); | 935 callbackMap.remove(message.header.requestId); |
905 if (c.isCompleted) { | 936 callback(r.photoUrl ); |
906 proxyError("Response completer already completed"); | |
907 return; | |
908 } | |
909 c.complete(r); | |
910 break; | 937 break; |
911 default: | 938 default: |
912 proxyError("Unexpected message type: ${message.header.type}"); | 939 proxyError("Unexpected message type: ${message.header.type}"); |
913 close(immediate: true); | 940 close(immediate: true); |
914 break; | 941 break; |
915 } | 942 } |
916 } | 943 } |
917 | 944 |
918 @override | 945 @override |
919 String toString() { | 946 String toString() { |
(...skipping 24 matching lines...) Expand all Loading... |
944 return newMockedProxy; | 971 return newMockedProxy; |
945 } | 972 } |
946 | 973 |
947 static ContactsServiceProxy newFromEndpoint( | 974 static ContactsServiceProxy newFromEndpoint( |
948 core.MojoMessagePipeEndpoint endpoint) { | 975 core.MojoMessagePipeEndpoint endpoint) { |
949 assert(endpoint.setDescription("For ContactsServiceProxy")); | 976 assert(endpoint.setDescription("For ContactsServiceProxy")); |
950 return new ContactsServiceProxy.fromEndpoint(endpoint); | 977 return new ContactsServiceProxy.fromEndpoint(endpoint); |
951 } | 978 } |
952 | 979 |
953 | 980 |
954 dynamic getCount(String filter,[Function responseFactory = null]) { | 981 void getCount(String filter,void callback(int count)) { |
955 if (impl != null) { | 982 if (impl != null) { |
956 return new Future(() => impl.getCount(filter,_ContactsServiceStubControl._
contactsServiceGetCountResponseParamsFactory)); | 983 impl.getCount(filter,callback); |
| 984 return; |
957 } | 985 } |
958 var params = new _ContactsServiceGetCountParams(); | 986 var params = new _ContactsServiceGetCountParams(); |
959 params.filter = filter; | 987 params.filter = filter; |
960 return ctrl.sendMessageWithRequestId( | 988 ctrl.sendMessageWithRequestId( |
961 params, | 989 params, |
962 _contactsServiceMethodGetCountName, | 990 _contactsServiceMethodGetCountName, |
963 -1, | 991 -1, |
964 bindings.MessageHeader.kMessageExpectsResponse); | 992 bindings.MessageHeader.kMessageExpectsResponse, |
| 993 callback); |
965 } | 994 } |
966 dynamic get(String filter,int offset,int limit,[Function responseFactory = nul
l]) { | 995 void get(String filter,int offset,int limit,void callback(List<Contact> contac
ts)) { |
967 if (impl != null) { | 996 if (impl != null) { |
968 return new Future(() => impl.get(filter,offset,limit,_ContactsServiceStubC
ontrol._contactsServiceGetResponseParamsFactory)); | 997 impl.get(filter,offset,limit,callback); |
| 998 return; |
969 } | 999 } |
970 var params = new _ContactsServiceGetParams(); | 1000 var params = new _ContactsServiceGetParams(); |
971 params.filter = filter; | 1001 params.filter = filter; |
972 params.offset = offset; | 1002 params.offset = offset; |
973 params.limit = limit; | 1003 params.limit = limit; |
974 return ctrl.sendMessageWithRequestId( | 1004 ctrl.sendMessageWithRequestId( |
975 params, | 1005 params, |
976 _contactsServiceMethodGetName, | 1006 _contactsServiceMethodGetName, |
977 -1, | 1007 -1, |
978 bindings.MessageHeader.kMessageExpectsResponse); | 1008 bindings.MessageHeader.kMessageExpectsResponse, |
| 1009 callback); |
979 } | 1010 } |
980 dynamic getEmails(int id,[Function responseFactory = null]) { | 1011 void getEmails(int id,void callback(List<String> emails)) { |
981 if (impl != null) { | 1012 if (impl != null) { |
982 return new Future(() => impl.getEmails(id,_ContactsServiceStubControl._con
tactsServiceGetEmailsResponseParamsFactory)); | 1013 impl.getEmails(id,callback); |
| 1014 return; |
983 } | 1015 } |
984 var params = new _ContactsServiceGetEmailsParams(); | 1016 var params = new _ContactsServiceGetEmailsParams(); |
985 params.id = id; | 1017 params.id = id; |
986 return ctrl.sendMessageWithRequestId( | 1018 ctrl.sendMessageWithRequestId( |
987 params, | 1019 params, |
988 _contactsServiceMethodGetEmailsName, | 1020 _contactsServiceMethodGetEmailsName, |
989 -1, | 1021 -1, |
990 bindings.MessageHeader.kMessageExpectsResponse); | 1022 bindings.MessageHeader.kMessageExpectsResponse, |
| 1023 callback); |
991 } | 1024 } |
992 dynamic getPhoto(int id,bool highResolution,[Function responseFactory = null])
{ | 1025 void getPhoto(int id,bool highResolution,void callback(String photoUrl)) { |
993 if (impl != null) { | 1026 if (impl != null) { |
994 return new Future(() => impl.getPhoto(id,highResolution,_ContactsServiceSt
ubControl._contactsServiceGetPhotoResponseParamsFactory)); | 1027 impl.getPhoto(id,highResolution,callback); |
| 1028 return; |
995 } | 1029 } |
996 var params = new _ContactsServiceGetPhotoParams(); | 1030 var params = new _ContactsServiceGetPhotoParams(); |
997 params.id = id; | 1031 params.id = id; |
998 params.highResolution = highResolution; | 1032 params.highResolution = highResolution; |
999 return ctrl.sendMessageWithRequestId( | 1033 ctrl.sendMessageWithRequestId( |
1000 params, | 1034 params, |
1001 _contactsServiceMethodGetPhotoName, | 1035 _contactsServiceMethodGetPhotoName, |
1002 -1, | 1036 -1, |
1003 bindings.MessageHeader.kMessageExpectsResponse); | 1037 bindings.MessageHeader.kMessageExpectsResponse, |
| 1038 callback); |
1004 } | 1039 } |
1005 } | 1040 } |
1006 | 1041 |
1007 class _ContactsServiceStubControl | 1042 class _ContactsServiceStubControl |
1008 extends bindings.StubMessageHandler | 1043 extends bindings.StubMessageHandler |
1009 implements bindings.StubControl<ContactsService> { | 1044 implements bindings.StubControl<ContactsService> { |
1010 ContactsService _impl; | 1045 ContactsService _impl; |
1011 | 1046 |
1012 _ContactsServiceStubControl.fromEndpoint( | 1047 _ContactsServiceStubControl.fromEndpoint( |
1013 core.MojoMessagePipeEndpoint endpoint, [ContactsService impl]) | 1048 core.MojoMessagePipeEndpoint endpoint, [ContactsService impl]) |
1014 : super.fromEndpoint(endpoint, autoBegin: impl != null) { | 1049 : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
1015 _impl = impl; | 1050 _impl = impl; |
1016 } | 1051 } |
1017 | 1052 |
1018 _ContactsServiceStubControl.fromHandle( | 1053 _ContactsServiceStubControl.fromHandle( |
1019 core.MojoHandle handle, [ContactsService impl]) | 1054 core.MojoHandle handle, [ContactsService impl]) |
1020 : super.fromHandle(handle, autoBegin: impl != null) { | 1055 : super.fromHandle(handle, autoBegin: impl != null) { |
1021 _impl = impl; | 1056 _impl = impl; |
1022 } | 1057 } |
1023 | 1058 |
1024 _ContactsServiceStubControl.unbound([this._impl]) : super.unbound(); | 1059 _ContactsServiceStubControl.unbound([this._impl]) : super.unbound(); |
1025 | 1060 |
1026 String get serviceName => ContactsService.serviceName; | 1061 String get serviceName => ContactsService.serviceName; |
1027 | 1062 |
1028 | 1063 |
1029 static ContactsServiceGetCountResponseParams _contactsServiceGetCountResponseP
aramsFactory(int count) { | 1064 Function _contactsServiceGetCountResponseParamsResponder( |
1030 var result = new ContactsServiceGetCountResponseParams(); | 1065 int requestId) { |
1031 result.count = count; | 1066 return (int count) { |
1032 return result; | 1067 var result = new ContactsServiceGetCountResponseParams(); |
| 1068 result.count = count; |
| 1069 sendResponse(buildResponseWithId( |
| 1070 result, |
| 1071 _contactsServiceMethodGetCountName, |
| 1072 requestId, |
| 1073 bindings.MessageHeader.kMessageIsResponse)); |
| 1074 }; |
1033 } | 1075 } |
1034 static ContactsServiceGetResponseParams _contactsServiceGetResponseParamsFacto
ry(List<Contact> contacts) { | 1076 Function _contactsServiceGetResponseParamsResponder( |
1035 var result = new ContactsServiceGetResponseParams(); | 1077 int requestId) { |
1036 result.contacts = contacts; | 1078 return (List<Contact> contacts) { |
1037 return result; | 1079 var result = new ContactsServiceGetResponseParams(); |
| 1080 result.contacts = contacts; |
| 1081 sendResponse(buildResponseWithId( |
| 1082 result, |
| 1083 _contactsServiceMethodGetName, |
| 1084 requestId, |
| 1085 bindings.MessageHeader.kMessageIsResponse)); |
| 1086 }; |
1038 } | 1087 } |
1039 static ContactsServiceGetEmailsResponseParams _contactsServiceGetEmailsRespons
eParamsFactory(List<String> emails) { | 1088 Function _contactsServiceGetEmailsResponseParamsResponder( |
1040 var result = new ContactsServiceGetEmailsResponseParams(); | 1089 int requestId) { |
1041 result.emails = emails; | 1090 return (List<String> emails) { |
1042 return result; | 1091 var result = new ContactsServiceGetEmailsResponseParams(); |
| 1092 result.emails = emails; |
| 1093 sendResponse(buildResponseWithId( |
| 1094 result, |
| 1095 _contactsServiceMethodGetEmailsName, |
| 1096 requestId, |
| 1097 bindings.MessageHeader.kMessageIsResponse)); |
| 1098 }; |
1043 } | 1099 } |
1044 static ContactsServiceGetPhotoResponseParams _contactsServiceGetPhotoResponseP
aramsFactory(String photoUrl) { | 1100 Function _contactsServiceGetPhotoResponseParamsResponder( |
1045 var result = new ContactsServiceGetPhotoResponseParams(); | 1101 int requestId) { |
1046 result.photoUrl = photoUrl; | 1102 return (String photoUrl) { |
1047 return result; | 1103 var result = new ContactsServiceGetPhotoResponseParams(); |
| 1104 result.photoUrl = photoUrl; |
| 1105 sendResponse(buildResponseWithId( |
| 1106 result, |
| 1107 _contactsServiceMethodGetPhotoName, |
| 1108 requestId, |
| 1109 bindings.MessageHeader.kMessageIsResponse)); |
| 1110 }; |
1048 } | 1111 } |
1049 | 1112 |
1050 dynamic handleMessage(bindings.ServiceMessage message) { | 1113 void handleMessage(bindings.ServiceMessage message) { |
1051 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 1114 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
1052 return bindings.ControlMessageHandler.handleMessage(this, | 1115 bindings.ControlMessageHandler.handleMessage( |
1053 0, | 1116 this, 0, message); |
1054 message); | 1117 return; |
1055 } | 1118 } |
1056 if (_impl == null) { | 1119 if (_impl == null) { |
1057 throw new core.MojoApiError("$this has no implementation set"); | 1120 throw new core.MojoApiError("$this has no implementation set"); |
1058 } | 1121 } |
1059 switch (message.header.type) { | 1122 switch (message.header.type) { |
1060 case _contactsServiceMethodGetCountName: | 1123 case _contactsServiceMethodGetCountName: |
1061 var params = _ContactsServiceGetCountParams.deserialize( | 1124 var params = _ContactsServiceGetCountParams.deserialize( |
1062 message.payload); | 1125 message.payload); |
1063 var response = _impl.getCount(params.filter,_contactsServiceGetCountResp
onseParamsFactory); | 1126 _impl.getCount(params.filter, _contactsServiceGetCountResponseParamsResp
onder(message.header.requestId)); |
1064 if (response is Future) { | |
1065 return response.then((response) { | |
1066 if (response != null) { | |
1067 return buildResponseWithId( | |
1068 response, | |
1069 _contactsServiceMethodGetCountName, | |
1070 message.header.requestId, | |
1071 bindings.MessageHeader.kMessageIsResponse); | |
1072 } | |
1073 }); | |
1074 } else if (response != null) { | |
1075 return buildResponseWithId( | |
1076 response, | |
1077 _contactsServiceMethodGetCountName, | |
1078 message.header.requestId, | |
1079 bindings.MessageHeader.kMessageIsResponse); | |
1080 } | |
1081 break; | 1127 break; |
1082 case _contactsServiceMethodGetName: | 1128 case _contactsServiceMethodGetName: |
1083 var params = _ContactsServiceGetParams.deserialize( | 1129 var params = _ContactsServiceGetParams.deserialize( |
1084 message.payload); | 1130 message.payload); |
1085 var response = _impl.get(params.filter,params.offset,params.limit,_conta
ctsServiceGetResponseParamsFactory); | 1131 _impl.get(params.filter, params.offset, params.limit, _contactsServiceGe
tResponseParamsResponder(message.header.requestId)); |
1086 if (response is Future) { | |
1087 return response.then((response) { | |
1088 if (response != null) { | |
1089 return buildResponseWithId( | |
1090 response, | |
1091 _contactsServiceMethodGetName, | |
1092 message.header.requestId, | |
1093 bindings.MessageHeader.kMessageIsResponse); | |
1094 } | |
1095 }); | |
1096 } else if (response != null) { | |
1097 return buildResponseWithId( | |
1098 response, | |
1099 _contactsServiceMethodGetName, | |
1100 message.header.requestId, | |
1101 bindings.MessageHeader.kMessageIsResponse); | |
1102 } | |
1103 break; | 1132 break; |
1104 case _contactsServiceMethodGetEmailsName: | 1133 case _contactsServiceMethodGetEmailsName: |
1105 var params = _ContactsServiceGetEmailsParams.deserialize( | 1134 var params = _ContactsServiceGetEmailsParams.deserialize( |
1106 message.payload); | 1135 message.payload); |
1107 var response = _impl.getEmails(params.id,_contactsServiceGetEmailsRespon
seParamsFactory); | 1136 _impl.getEmails(params.id, _contactsServiceGetEmailsResponseParamsRespon
der(message.header.requestId)); |
1108 if (response is Future) { | |
1109 return response.then((response) { | |
1110 if (response != null) { | |
1111 return buildResponseWithId( | |
1112 response, | |
1113 _contactsServiceMethodGetEmailsName, | |
1114 message.header.requestId, | |
1115 bindings.MessageHeader.kMessageIsResponse); | |
1116 } | |
1117 }); | |
1118 } else if (response != null) { | |
1119 return buildResponseWithId( | |
1120 response, | |
1121 _contactsServiceMethodGetEmailsName, | |
1122 message.header.requestId, | |
1123 bindings.MessageHeader.kMessageIsResponse); | |
1124 } | |
1125 break; | 1137 break; |
1126 case _contactsServiceMethodGetPhotoName: | 1138 case _contactsServiceMethodGetPhotoName: |
1127 var params = _ContactsServiceGetPhotoParams.deserialize( | 1139 var params = _ContactsServiceGetPhotoParams.deserialize( |
1128 message.payload); | 1140 message.payload); |
1129 var response = _impl.getPhoto(params.id,params.highResolution,_contactsS
erviceGetPhotoResponseParamsFactory); | 1141 _impl.getPhoto(params.id, params.highResolution, _contactsServiceGetPhot
oResponseParamsResponder(message.header.requestId)); |
1130 if (response is Future) { | |
1131 return response.then((response) { | |
1132 if (response != null) { | |
1133 return buildResponseWithId( | |
1134 response, | |
1135 _contactsServiceMethodGetPhotoName, | |
1136 message.header.requestId, | |
1137 bindings.MessageHeader.kMessageIsResponse); | |
1138 } | |
1139 }); | |
1140 } else if (response != null) { | |
1141 return buildResponseWithId( | |
1142 response, | |
1143 _contactsServiceMethodGetPhotoName, | |
1144 message.header.requestId, | |
1145 bindings.MessageHeader.kMessageIsResponse); | |
1146 } | |
1147 break; | 1142 break; |
1148 default: | 1143 default: |
1149 throw new bindings.MojoCodecError("Unexpected message name"); | 1144 throw new bindings.MojoCodecError("Unexpected message name"); |
1150 break; | 1145 break; |
1151 } | 1146 } |
1152 return null; | |
1153 } | 1147 } |
1154 | 1148 |
1155 ContactsService get impl => _impl; | 1149 ContactsService get impl => _impl; |
1156 set impl(ContactsService d) { | 1150 set impl(ContactsService d) { |
1157 if (d == null) { | 1151 if (d == null) { |
1158 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 1152 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
1159 } | 1153 } |
1160 if (isBound && (_impl == null)) { | 1154 if (isBound && (_impl == null)) { |
1161 beginHandlingEvents(); | 1155 beginHandlingEvents(); |
1162 } | 1156 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1196 core.MojoHandle handle, [ContactsService impl]) | 1190 core.MojoHandle handle, [ContactsService impl]) |
1197 : super(new _ContactsServiceStubControl.fromHandle(handle, impl)); | 1191 : super(new _ContactsServiceStubControl.fromHandle(handle, impl)); |
1198 | 1192 |
1199 static ContactsServiceStub newFromEndpoint( | 1193 static ContactsServiceStub newFromEndpoint( |
1200 core.MojoMessagePipeEndpoint endpoint) { | 1194 core.MojoMessagePipeEndpoint endpoint) { |
1201 assert(endpoint.setDescription("For ContactsServiceStub")); | 1195 assert(endpoint.setDescription("For ContactsServiceStub")); |
1202 return new ContactsServiceStub.fromEndpoint(endpoint); | 1196 return new ContactsServiceStub.fromEndpoint(endpoint); |
1203 } | 1197 } |
1204 | 1198 |
1205 | 1199 |
1206 dynamic getCount(String filter,[Function responseFactory = null]) { | 1200 void getCount(String filter,void callback(int count)) { |
1207 return impl.getCount(filter,responseFactory); | 1201 return impl.getCount(filter,callback); |
1208 } | 1202 } |
1209 dynamic get(String filter,int offset,int limit,[Function responseFactory = nul
l]) { | 1203 void get(String filter,int offset,int limit,void callback(List<Contact> contac
ts)) { |
1210 return impl.get(filter,offset,limit,responseFactory); | 1204 return impl.get(filter,offset,limit,callback); |
1211 } | 1205 } |
1212 dynamic getEmails(int id,[Function responseFactory = null]) { | 1206 void getEmails(int id,void callback(List<String> emails)) { |
1213 return impl.getEmails(id,responseFactory); | 1207 return impl.getEmails(id,callback); |
1214 } | 1208 } |
1215 dynamic getPhoto(int id,bool highResolution,[Function responseFactory = null])
{ | 1209 void getPhoto(int id,bool highResolution,void callback(String photoUrl)) { |
1216 return impl.getPhoto(id,highResolution,responseFactory); | 1210 return impl.getPhoto(id,highResolution,callback); |
1217 } | 1211 } |
1218 } | 1212 } |
1219 | 1213 |
1220 | 1214 |
1221 | 1215 |
OLD | NEW |