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

Side by Side Diff: mojo/dart/packages/mojo_services/lib/mojo/url_response_disk_cache.mojom.dart

Issue 2006093002: Dart: Futures -> Callbacks. (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Merge Created 4 years, 6 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 unified diff | Download patch
OLDNEW
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 url_response_disk_cache_mojom; 4 library url_response_disk_cache_mojom;
5 import 'dart:async'; 5 import 'dart:async';
6 import 'package:mojo/bindings.dart' as bindings; 6 import 'package:mojo/bindings.dart' as bindings;
7 import 'package:mojo/core.dart' as core; 7 import 'package:mojo/core.dart' as core;
8 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic e_describer; 8 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic e_describer;
9 import 'package:mojo/mojo/url_response.mojom.dart' as url_response_mojom; 9 import 'package:mojo/mojo/url_response.mojom.dart' as url_response_mojom;
10 10
11 11
12 12
13 class _UrlResponseDiskCacheGetParams extends bindings.Struct { 13 class _UrlResponseDiskCacheGetParams extends bindings.Struct {
14 static const List<bindings.StructDataHeader> kVersions = const [ 14 static const List<bindings.StructDataHeader> kVersions = const [
15 const bindings.StructDataHeader(16, 0) 15 const bindings.StructDataHeader(16, 0)
16 ]; 16 ];
17 String url = null; 17 String url = null;
18 18
19 _UrlResponseDiskCacheGetParams() : super(kVersions.last.size); 19 _UrlResponseDiskCacheGetParams() : super(kVersions.last.size);
20 20
21 _UrlResponseDiskCacheGetParams.init(
22 String this.url
23 ) : super(kVersions.last.size);
24
21 static _UrlResponseDiskCacheGetParams deserialize(bindings.Message message) { 25 static _UrlResponseDiskCacheGetParams deserialize(bindings.Message message) {
22 var decoder = new bindings.Decoder(message); 26 var decoder = new bindings.Decoder(message);
23 var result = decode(decoder); 27 var result = decode(decoder);
24 if (decoder.excessHandles != null) { 28 if (decoder.excessHandles != null) {
25 decoder.excessHandles.forEach((h) => h.close()); 29 decoder.excessHandles.forEach((h) => h.close());
26 } 30 }
27 return result; 31 return result;
28 } 32 }
29 33
30 static _UrlResponseDiskCacheGetParams decode(bindings.Decoder decoder0) { 34 static _UrlResponseDiskCacheGetParams decode(bindings.Decoder decoder0) {
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after
85 class UrlResponseDiskCacheGetResponseParams extends bindings.Struct { 89 class UrlResponseDiskCacheGetResponseParams extends bindings.Struct {
86 static const List<bindings.StructDataHeader> kVersions = const [ 90 static const List<bindings.StructDataHeader> kVersions = const [
87 const bindings.StructDataHeader(32, 0) 91 const bindings.StructDataHeader(32, 0)
88 ]; 92 ];
89 url_response_mojom.UrlResponse response = null; 93 url_response_mojom.UrlResponse response = null;
90 List<int> filePath = null; 94 List<int> filePath = null;
91 List<int> cacheDirPath = null; 95 List<int> cacheDirPath = null;
92 96
93 UrlResponseDiskCacheGetResponseParams() : super(kVersions.last.size); 97 UrlResponseDiskCacheGetResponseParams() : super(kVersions.last.size);
94 98
99 UrlResponseDiskCacheGetResponseParams.init(
100 url_response_mojom.UrlResponse this.response,
101 List<int> this.filePath,
102 List<int> this.cacheDirPath
103 ) : super(kVersions.last.size);
104
95 static UrlResponseDiskCacheGetResponseParams deserialize(bindings.Message mess age) { 105 static UrlResponseDiskCacheGetResponseParams deserialize(bindings.Message mess age) {
96 var decoder = new bindings.Decoder(message); 106 var decoder = new bindings.Decoder(message);
97 var result = decode(decoder); 107 var result = decode(decoder);
98 if (decoder.excessHandles != null) { 108 if (decoder.excessHandles != null) {
99 decoder.excessHandles.forEach((h) => h.close()); 109 decoder.excessHandles.forEach((h) => h.close());
100 } 110 }
101 return result; 111 return result;
102 } 112 }
103 113
104 static UrlResponseDiskCacheGetResponseParams decode(bindings.Decoder decoder0) { 114 static UrlResponseDiskCacheGetResponseParams decode(bindings.Decoder decoder0) {
(...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after
181 191
182 192
183 class _UrlResponseDiskCacheValidateParams extends bindings.Struct { 193 class _UrlResponseDiskCacheValidateParams extends bindings.Struct {
184 static const List<bindings.StructDataHeader> kVersions = const [ 194 static const List<bindings.StructDataHeader> kVersions = const [
185 const bindings.StructDataHeader(16, 0) 195 const bindings.StructDataHeader(16, 0)
186 ]; 196 ];
187 String url = null; 197 String url = null;
188 198
189 _UrlResponseDiskCacheValidateParams() : super(kVersions.last.size); 199 _UrlResponseDiskCacheValidateParams() : super(kVersions.last.size);
190 200
201 _UrlResponseDiskCacheValidateParams.init(
202 String this.url
203 ) : super(kVersions.last.size);
204
191 static _UrlResponseDiskCacheValidateParams deserialize(bindings.Message messag e) { 205 static _UrlResponseDiskCacheValidateParams deserialize(bindings.Message messag e) {
192 var decoder = new bindings.Decoder(message); 206 var decoder = new bindings.Decoder(message);
193 var result = decode(decoder); 207 var result = decode(decoder);
194 if (decoder.excessHandles != null) { 208 if (decoder.excessHandles != null) {
195 decoder.excessHandles.forEach((h) => h.close()); 209 decoder.excessHandles.forEach((h) => h.close());
196 } 210 }
197 return result; 211 return result;
198 } 212 }
199 213
200 static _UrlResponseDiskCacheValidateParams decode(bindings.Decoder decoder0) { 214 static _UrlResponseDiskCacheValidateParams decode(bindings.Decoder decoder0) {
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after
253 267
254 268
255 class _UrlResponseDiskCacheUpdateParams extends bindings.Struct { 269 class _UrlResponseDiskCacheUpdateParams extends bindings.Struct {
256 static const List<bindings.StructDataHeader> kVersions = const [ 270 static const List<bindings.StructDataHeader> kVersions = const [
257 const bindings.StructDataHeader(16, 0) 271 const bindings.StructDataHeader(16, 0)
258 ]; 272 ];
259 url_response_mojom.UrlResponse response = null; 273 url_response_mojom.UrlResponse response = null;
260 274
261 _UrlResponseDiskCacheUpdateParams() : super(kVersions.last.size); 275 _UrlResponseDiskCacheUpdateParams() : super(kVersions.last.size);
262 276
277 _UrlResponseDiskCacheUpdateParams.init(
278 url_response_mojom.UrlResponse this.response
279 ) : super(kVersions.last.size);
280
263 static _UrlResponseDiskCacheUpdateParams deserialize(bindings.Message message) { 281 static _UrlResponseDiskCacheUpdateParams deserialize(bindings.Message message) {
264 var decoder = new bindings.Decoder(message); 282 var decoder = new bindings.Decoder(message);
265 var result = decode(decoder); 283 var result = decode(decoder);
266 if (decoder.excessHandles != null) { 284 if (decoder.excessHandles != null) {
267 decoder.excessHandles.forEach((h) => h.close()); 285 decoder.excessHandles.forEach((h) => h.close());
268 } 286 }
269 return result; 287 return result;
270 } 288 }
271 289
272 static _UrlResponseDiskCacheUpdateParams decode(bindings.Decoder decoder0) { 290 static _UrlResponseDiskCacheUpdateParams decode(bindings.Decoder decoder0) {
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after
325 343
326 344
327 class _UrlResponseDiskCacheUpdateAndGetParams extends bindings.Struct { 345 class _UrlResponseDiskCacheUpdateAndGetParams extends bindings.Struct {
328 static const List<bindings.StructDataHeader> kVersions = const [ 346 static const List<bindings.StructDataHeader> kVersions = const [
329 const bindings.StructDataHeader(16, 0) 347 const bindings.StructDataHeader(16, 0)
330 ]; 348 ];
331 url_response_mojom.UrlResponse response = null; 349 url_response_mojom.UrlResponse response = null;
332 350
333 _UrlResponseDiskCacheUpdateAndGetParams() : super(kVersions.last.size); 351 _UrlResponseDiskCacheUpdateAndGetParams() : super(kVersions.last.size);
334 352
353 _UrlResponseDiskCacheUpdateAndGetParams.init(
354 url_response_mojom.UrlResponse this.response
355 ) : super(kVersions.last.size);
356
335 static _UrlResponseDiskCacheUpdateAndGetParams deserialize(bindings.Message me ssage) { 357 static _UrlResponseDiskCacheUpdateAndGetParams deserialize(bindings.Message me ssage) {
336 var decoder = new bindings.Decoder(message); 358 var decoder = new bindings.Decoder(message);
337 var result = decode(decoder); 359 var result = decode(decoder);
338 if (decoder.excessHandles != null) { 360 if (decoder.excessHandles != null) {
339 decoder.excessHandles.forEach((h) => h.close()); 361 decoder.excessHandles.forEach((h) => h.close());
340 } 362 }
341 return result; 363 return result;
342 } 364 }
343 365
344 static _UrlResponseDiskCacheUpdateAndGetParams decode(bindings.Decoder decoder 0) { 366 static _UrlResponseDiskCacheUpdateAndGetParams decode(bindings.Decoder decoder 0) {
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after
398 420
399 class UrlResponseDiskCacheUpdateAndGetResponseParams extends bindings.Struct { 421 class UrlResponseDiskCacheUpdateAndGetResponseParams extends bindings.Struct {
400 static const List<bindings.StructDataHeader> kVersions = const [ 422 static const List<bindings.StructDataHeader> kVersions = const [
401 const bindings.StructDataHeader(24, 0) 423 const bindings.StructDataHeader(24, 0)
402 ]; 424 ];
403 List<int> filePath = null; 425 List<int> filePath = null;
404 List<int> cacheDirPath = null; 426 List<int> cacheDirPath = null;
405 427
406 UrlResponseDiskCacheUpdateAndGetResponseParams() : super(kVersions.last.size); 428 UrlResponseDiskCacheUpdateAndGetResponseParams() : super(kVersions.last.size);
407 429
430 UrlResponseDiskCacheUpdateAndGetResponseParams.init(
431 List<int> this.filePath,
432 List<int> this.cacheDirPath
433 ) : super(kVersions.last.size);
434
408 static UrlResponseDiskCacheUpdateAndGetResponseParams deserialize(bindings.Mes sage message) { 435 static UrlResponseDiskCacheUpdateAndGetResponseParams deserialize(bindings.Mes sage message) {
409 var decoder = new bindings.Decoder(message); 436 var decoder = new bindings.Decoder(message);
410 var result = decode(decoder); 437 var result = decode(decoder);
411 if (decoder.excessHandles != null) { 438 if (decoder.excessHandles != null) {
412 decoder.excessHandles.forEach((h) => h.close()); 439 decoder.excessHandles.forEach((h) => h.close());
413 } 440 }
414 return result; 441 return result;
415 } 442 }
416 443
417 static UrlResponseDiskCacheUpdateAndGetResponseParams decode(bindings.Decoder decoder0) { 444 static UrlResponseDiskCacheUpdateAndGetResponseParams decode(bindings.Decoder decoder0) {
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after
483 510
484 511
485 class _UrlResponseDiskCacheUpdateAndGetExtractedParams extends bindings.Struct { 512 class _UrlResponseDiskCacheUpdateAndGetExtractedParams extends bindings.Struct {
486 static const List<bindings.StructDataHeader> kVersions = const [ 513 static const List<bindings.StructDataHeader> kVersions = const [
487 const bindings.StructDataHeader(16, 0) 514 const bindings.StructDataHeader(16, 0)
488 ]; 515 ];
489 url_response_mojom.UrlResponse response = null; 516 url_response_mojom.UrlResponse response = null;
490 517
491 _UrlResponseDiskCacheUpdateAndGetExtractedParams() : super(kVersions.last.size ); 518 _UrlResponseDiskCacheUpdateAndGetExtractedParams() : super(kVersions.last.size );
492 519
520 _UrlResponseDiskCacheUpdateAndGetExtractedParams.init(
521 url_response_mojom.UrlResponse this.response
522 ) : super(kVersions.last.size);
523
493 static _UrlResponseDiskCacheUpdateAndGetExtractedParams deserialize(bindings.M essage message) { 524 static _UrlResponseDiskCacheUpdateAndGetExtractedParams deserialize(bindings.M essage message) {
494 var decoder = new bindings.Decoder(message); 525 var decoder = new bindings.Decoder(message);
495 var result = decode(decoder); 526 var result = decode(decoder);
496 if (decoder.excessHandles != null) { 527 if (decoder.excessHandles != null) {
497 decoder.excessHandles.forEach((h) => h.close()); 528 decoder.excessHandles.forEach((h) => h.close());
498 } 529 }
499 return result; 530 return result;
500 } 531 }
501 532
502 static _UrlResponseDiskCacheUpdateAndGetExtractedParams decode(bindings.Decode r decoder0) { 533 static _UrlResponseDiskCacheUpdateAndGetExtractedParams decode(bindings.Decode r decoder0) {
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after
556 587
557 class UrlResponseDiskCacheUpdateAndGetExtractedResponseParams extends bindings.S truct { 588 class UrlResponseDiskCacheUpdateAndGetExtractedResponseParams extends bindings.S truct {
558 static const List<bindings.StructDataHeader> kVersions = const [ 589 static const List<bindings.StructDataHeader> kVersions = const [
559 const bindings.StructDataHeader(24, 0) 590 const bindings.StructDataHeader(24, 0)
560 ]; 591 ];
561 List<int> extractedDirPath = null; 592 List<int> extractedDirPath = null;
562 List<int> cacheDirPath = null; 593 List<int> cacheDirPath = null;
563 594
564 UrlResponseDiskCacheUpdateAndGetExtractedResponseParams() : super(kVersions.la st.size); 595 UrlResponseDiskCacheUpdateAndGetExtractedResponseParams() : super(kVersions.la st.size);
565 596
597 UrlResponseDiskCacheUpdateAndGetExtractedResponseParams.init(
598 List<int> this.extractedDirPath,
599 List<int> this.cacheDirPath
600 ) : super(kVersions.last.size);
601
566 static UrlResponseDiskCacheUpdateAndGetExtractedResponseParams deserialize(bin dings.Message message) { 602 static UrlResponseDiskCacheUpdateAndGetExtractedResponseParams deserialize(bin dings.Message message) {
567 var decoder = new bindings.Decoder(message); 603 var decoder = new bindings.Decoder(message);
568 var result = decode(decoder); 604 var result = decode(decoder);
569 if (decoder.excessHandles != null) { 605 if (decoder.excessHandles != null) {
570 decoder.excessHandles.forEach((h) => h.close()); 606 decoder.excessHandles.forEach((h) => h.close());
571 } 607 }
572 return result; 608 return result;
573 } 609 }
574 610
575 static UrlResponseDiskCacheUpdateAndGetExtractedResponseParams decode(bindings .Decoder decoder0) { 611 static UrlResponseDiskCacheUpdateAndGetExtractedResponseParams decode(bindings .Decoder decoder0) {
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after
639 } 675 }
640 } 676 }
641 677
642 const int _urlResponseDiskCacheMethodGetName = 0; 678 const int _urlResponseDiskCacheMethodGetName = 0;
643 const int _urlResponseDiskCacheMethodValidateName = 1; 679 const int _urlResponseDiskCacheMethodValidateName = 1;
644 const int _urlResponseDiskCacheMethodUpdateName = 2; 680 const int _urlResponseDiskCacheMethodUpdateName = 2;
645 const int _urlResponseDiskCacheMethodUpdateAndGetName = 3; 681 const int _urlResponseDiskCacheMethodUpdateAndGetName = 3;
646 const int _urlResponseDiskCacheMethodUpdateAndGetExtractedName = 4; 682 const int _urlResponseDiskCacheMethodUpdateAndGetExtractedName = 4;
647 683
648 class _UrlResponseDiskCacheServiceDescription implements service_describer.Servi ceDescription { 684 class _UrlResponseDiskCacheServiceDescription implements service_describer.Servi ceDescription {
649 dynamic getTopLevelInterface([Function responseFactory]) => 685 void getTopLevelInterface(Function responder) {
650 responseFactory(null); 686 responder(null);
687 }
651 688
652 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => 689 void getTypeDefinition(String typeKey, Function responder) {
653 responseFactory(null); 690 responder(null);
691 }
654 692
655 dynamic getAllTypeDefinitions([Function responseFactory]) => 693 void getAllTypeDefinitions(Function responder) {
656 responseFactory(null); 694 responder(null);
695 }
657 } 696 }
658 697
659 abstract class UrlResponseDiskCache { 698 abstract class UrlResponseDiskCache {
660 static const String serviceName = "mojo::URLResponseDiskCache"; 699 static const String serviceName = "mojo::URLResponseDiskCache";
661 700
662 static service_describer.ServiceDescription _cachedServiceDescription; 701 static service_describer.ServiceDescription _cachedServiceDescription;
663 static service_describer.ServiceDescription get serviceDescription { 702 static service_describer.ServiceDescription get serviceDescription {
664 if (_cachedServiceDescription == null) { 703 if (_cachedServiceDescription == null) {
665 _cachedServiceDescription = new _UrlResponseDiskCacheServiceDescription(); 704 _cachedServiceDescription = new _UrlResponseDiskCacheServiceDescription();
666 } 705 }
667 return _cachedServiceDescription; 706 return _cachedServiceDescription;
668 } 707 }
669 708
670 static UrlResponseDiskCacheProxy connectToService( 709 static UrlResponseDiskCacheProxy connectToService(
671 bindings.ServiceConnector s, String url, [String serviceName]) { 710 bindings.ServiceConnector s, String url, [String serviceName]) {
672 UrlResponseDiskCacheProxy p = new UrlResponseDiskCacheProxy.unbound(); 711 UrlResponseDiskCacheProxy p = new UrlResponseDiskCacheProxy.unbound();
673 String name = serviceName ?? UrlResponseDiskCache.serviceName; 712 String name = serviceName ?? UrlResponseDiskCache.serviceName;
674 if ((name == null) || name.isEmpty) { 713 if ((name == null) || name.isEmpty) {
675 throw new core.MojoApiError( 714 throw new core.MojoApiError(
676 "If an interface has no ServiceName, then one must be provided."); 715 "If an interface has no ServiceName, then one must be provided.");
677 } 716 }
678 s.connectToService(url, p, name); 717 s.connectToService(url, p, name);
679 return p; 718 return p;
680 } 719 }
681 dynamic get(String url,[Function responseFactory = null]); 720 void get(String url,void callback(url_response_mojom.UrlResponse response, Lis t<int> filePath, List<int> cacheDirPath));
682 void validate(String url); 721 void validate(String url);
683 void update(url_response_mojom.UrlResponse response); 722 void update(url_response_mojom.UrlResponse response);
684 dynamic updateAndGet(url_response_mojom.UrlResponse response,[Function respons eFactory = null]); 723 void updateAndGet(url_response_mojom.UrlResponse response,void callback(List<i nt> filePath, List<int> cacheDirPath));
685 dynamic updateAndGetExtracted(url_response_mojom.UrlResponse response,[Functio n responseFactory = null]); 724 void updateAndGetExtracted(url_response_mojom.UrlResponse response,void callba ck(List<int> extractedDirPath, List<int> cacheDirPath));
686 } 725 }
687 726
688 abstract class UrlResponseDiskCacheInterface 727 abstract class UrlResponseDiskCacheInterface
689 implements bindings.MojoInterface<UrlResponseDiskCache>, 728 implements bindings.MojoInterface<UrlResponseDiskCache>,
690 UrlResponseDiskCache { 729 UrlResponseDiskCache {
691 factory UrlResponseDiskCacheInterface([UrlResponseDiskCache impl]) => 730 factory UrlResponseDiskCacheInterface([UrlResponseDiskCache impl]) =>
692 new UrlResponseDiskCacheStub.unbound(impl); 731 new UrlResponseDiskCacheStub.unbound(impl);
693 732
694 factory UrlResponseDiskCacheInterface.fromEndpoint( 733 factory UrlResponseDiskCacheInterface.fromEndpoint(
695 core.MojoMessagePipeEndpoint endpoint, 734 core.MojoMessagePipeEndpoint endpoint,
(...skipping 29 matching lines...) Expand all
725 764
726 void handleResponse(bindings.ServiceMessage message) { 765 void handleResponse(bindings.ServiceMessage message) {
727 switch (message.header.type) { 766 switch (message.header.type) {
728 case _urlResponseDiskCacheMethodGetName: 767 case _urlResponseDiskCacheMethodGetName:
729 var r = UrlResponseDiskCacheGetResponseParams.deserialize( 768 var r = UrlResponseDiskCacheGetResponseParams.deserialize(
730 message.payload); 769 message.payload);
731 if (!message.header.hasRequestId) { 770 if (!message.header.hasRequestId) {
732 proxyError("Expected a message with a valid request Id."); 771 proxyError("Expected a message with a valid request Id.");
733 return; 772 return;
734 } 773 }
735 Completer c = completerMap[message.header.requestId]; 774 Function callback = callbackMap[message.header.requestId];
736 if (c == null) { 775 if (callback == null) {
737 proxyError( 776 proxyError(
738 "Message had unknown request Id: ${message.header.requestId}"); 777 "Message had unknown request Id: ${message.header.requestId}");
739 return; 778 return;
740 } 779 }
741 completerMap.remove(message.header.requestId); 780 callbackMap.remove(message.header.requestId);
742 if (c.isCompleted) { 781 callback(r.response , r.filePath , r.cacheDirPath );
743 proxyError("Response completer already completed");
744 return;
745 }
746 c.complete(r);
747 break; 782 break;
748 case _urlResponseDiskCacheMethodUpdateAndGetName: 783 case _urlResponseDiskCacheMethodUpdateAndGetName:
749 var r = UrlResponseDiskCacheUpdateAndGetResponseParams.deserialize( 784 var r = UrlResponseDiskCacheUpdateAndGetResponseParams.deserialize(
750 message.payload); 785 message.payload);
751 if (!message.header.hasRequestId) { 786 if (!message.header.hasRequestId) {
752 proxyError("Expected a message with a valid request Id."); 787 proxyError("Expected a message with a valid request Id.");
753 return; 788 return;
754 } 789 }
755 Completer c = completerMap[message.header.requestId]; 790 Function callback = callbackMap[message.header.requestId];
756 if (c == null) { 791 if (callback == null) {
757 proxyError( 792 proxyError(
758 "Message had unknown request Id: ${message.header.requestId}"); 793 "Message had unknown request Id: ${message.header.requestId}");
759 return; 794 return;
760 } 795 }
761 completerMap.remove(message.header.requestId); 796 callbackMap.remove(message.header.requestId);
762 if (c.isCompleted) { 797 callback(r.filePath , r.cacheDirPath );
763 proxyError("Response completer already completed");
764 return;
765 }
766 c.complete(r);
767 break; 798 break;
768 case _urlResponseDiskCacheMethodUpdateAndGetExtractedName: 799 case _urlResponseDiskCacheMethodUpdateAndGetExtractedName:
769 var r = UrlResponseDiskCacheUpdateAndGetExtractedResponseParams.deserial ize( 800 var r = UrlResponseDiskCacheUpdateAndGetExtractedResponseParams.deserial ize(
770 message.payload); 801 message.payload);
771 if (!message.header.hasRequestId) { 802 if (!message.header.hasRequestId) {
772 proxyError("Expected a message with a valid request Id."); 803 proxyError("Expected a message with a valid request Id.");
773 return; 804 return;
774 } 805 }
775 Completer c = completerMap[message.header.requestId]; 806 Function callback = callbackMap[message.header.requestId];
776 if (c == null) { 807 if (callback == null) {
777 proxyError( 808 proxyError(
778 "Message had unknown request Id: ${message.header.requestId}"); 809 "Message had unknown request Id: ${message.header.requestId}");
779 return; 810 return;
780 } 811 }
781 completerMap.remove(message.header.requestId); 812 callbackMap.remove(message.header.requestId);
782 if (c.isCompleted) { 813 callback(r.extractedDirPath , r.cacheDirPath );
783 proxyError("Response completer already completed");
784 return;
785 }
786 c.complete(r);
787 break; 814 break;
788 default: 815 default:
789 proxyError("Unexpected message type: ${message.header.type}"); 816 proxyError("Unexpected message type: ${message.header.type}");
790 close(immediate: true); 817 close(immediate: true);
791 break; 818 break;
792 } 819 }
793 } 820 }
794 821
795 @override 822 @override
796 String toString() { 823 String toString() {
(...skipping 24 matching lines...) Expand all
821 return newMockedProxy; 848 return newMockedProxy;
822 } 849 }
823 850
824 static UrlResponseDiskCacheProxy newFromEndpoint( 851 static UrlResponseDiskCacheProxy newFromEndpoint(
825 core.MojoMessagePipeEndpoint endpoint) { 852 core.MojoMessagePipeEndpoint endpoint) {
826 assert(endpoint.setDescription("For UrlResponseDiskCacheProxy")); 853 assert(endpoint.setDescription("For UrlResponseDiskCacheProxy"));
827 return new UrlResponseDiskCacheProxy.fromEndpoint(endpoint); 854 return new UrlResponseDiskCacheProxy.fromEndpoint(endpoint);
828 } 855 }
829 856
830 857
831 dynamic get(String url,[Function responseFactory = null]) { 858 void get(String url,void callback(url_response_mojom.UrlResponse response, Lis t<int> filePath, List<int> cacheDirPath)) {
832 if (impl != null) { 859 if (impl != null) {
833 return new Future(() => impl.get(url,_UrlResponseDiskCacheStubControl._url ResponseDiskCacheGetResponseParamsFactory)); 860 impl.get(url,callback);
861 return;
834 } 862 }
835 var params = new _UrlResponseDiskCacheGetParams(); 863 var params = new _UrlResponseDiskCacheGetParams();
836 params.url = url; 864 params.url = url;
837 return ctrl.sendMessageWithRequestId( 865 ctrl.sendMessageWithRequestId(
838 params, 866 params,
839 _urlResponseDiskCacheMethodGetName, 867 _urlResponseDiskCacheMethodGetName,
840 -1, 868 -1,
841 bindings.MessageHeader.kMessageExpectsResponse); 869 bindings.MessageHeader.kMessageExpectsResponse,
870 callback);
842 } 871 }
843 void validate(String url) { 872 void validate(String url) {
844 if (impl != null) { 873 if (impl != null) {
845 impl.validate(url); 874 impl.validate(url);
846 return; 875 return;
847 } 876 }
848 if (!ctrl.isBound) { 877 if (!ctrl.isBound) {
849 ctrl.proxyError("The Proxy is closed."); 878 ctrl.proxyError("The Proxy is closed.");
850 return; 879 return;
851 } 880 }
852 var params = new _UrlResponseDiskCacheValidateParams(); 881 var params = new _UrlResponseDiskCacheValidateParams();
853 params.url = url; 882 params.url = url;
854 ctrl.sendMessage(params, 883 ctrl.sendMessage(params,
855 _urlResponseDiskCacheMethodValidateName); 884 _urlResponseDiskCacheMethodValidateName);
856 } 885 }
857 void update(url_response_mojom.UrlResponse response) { 886 void update(url_response_mojom.UrlResponse response) {
858 if (impl != null) { 887 if (impl != null) {
859 impl.update(response); 888 impl.update(response);
860 return; 889 return;
861 } 890 }
862 if (!ctrl.isBound) { 891 if (!ctrl.isBound) {
863 ctrl.proxyError("The Proxy is closed."); 892 ctrl.proxyError("The Proxy is closed.");
864 return; 893 return;
865 } 894 }
866 var params = new _UrlResponseDiskCacheUpdateParams(); 895 var params = new _UrlResponseDiskCacheUpdateParams();
867 params.response = response; 896 params.response = response;
868 ctrl.sendMessage(params, 897 ctrl.sendMessage(params,
869 _urlResponseDiskCacheMethodUpdateName); 898 _urlResponseDiskCacheMethodUpdateName);
870 } 899 }
871 dynamic updateAndGet(url_response_mojom.UrlResponse response,[Function respons eFactory = null]) { 900 void updateAndGet(url_response_mojom.UrlResponse response,void callback(List<i nt> filePath, List<int> cacheDirPath)) {
872 if (impl != null) { 901 if (impl != null) {
873 return new Future(() => impl.updateAndGet(response,_UrlResponseDiskCacheSt ubControl._urlResponseDiskCacheUpdateAndGetResponseParamsFactory)); 902 impl.updateAndGet(response,callback);
903 return;
874 } 904 }
875 var params = new _UrlResponseDiskCacheUpdateAndGetParams(); 905 var params = new _UrlResponseDiskCacheUpdateAndGetParams();
876 params.response = response; 906 params.response = response;
877 return ctrl.sendMessageWithRequestId( 907 ctrl.sendMessageWithRequestId(
878 params, 908 params,
879 _urlResponseDiskCacheMethodUpdateAndGetName, 909 _urlResponseDiskCacheMethodUpdateAndGetName,
880 -1, 910 -1,
881 bindings.MessageHeader.kMessageExpectsResponse); 911 bindings.MessageHeader.kMessageExpectsResponse,
912 callback);
882 } 913 }
883 dynamic updateAndGetExtracted(url_response_mojom.UrlResponse response,[Functio n responseFactory = null]) { 914 void updateAndGetExtracted(url_response_mojom.UrlResponse response,void callba ck(List<int> extractedDirPath, List<int> cacheDirPath)) {
884 if (impl != null) { 915 if (impl != null) {
885 return new Future(() => impl.updateAndGetExtracted(response,_UrlResponseDi skCacheStubControl._urlResponseDiskCacheUpdateAndGetExtractedResponseParamsFacto ry)); 916 impl.updateAndGetExtracted(response,callback);
917 return;
886 } 918 }
887 var params = new _UrlResponseDiskCacheUpdateAndGetExtractedParams(); 919 var params = new _UrlResponseDiskCacheUpdateAndGetExtractedParams();
888 params.response = response; 920 params.response = response;
889 return ctrl.sendMessageWithRequestId( 921 ctrl.sendMessageWithRequestId(
890 params, 922 params,
891 _urlResponseDiskCacheMethodUpdateAndGetExtractedName, 923 _urlResponseDiskCacheMethodUpdateAndGetExtractedName,
892 -1, 924 -1,
893 bindings.MessageHeader.kMessageExpectsResponse); 925 bindings.MessageHeader.kMessageExpectsResponse,
926 callback);
894 } 927 }
895 } 928 }
896 929
897 class _UrlResponseDiskCacheStubControl 930 class _UrlResponseDiskCacheStubControl
898 extends bindings.StubMessageHandler 931 extends bindings.StubMessageHandler
899 implements bindings.StubControl<UrlResponseDiskCache> { 932 implements bindings.StubControl<UrlResponseDiskCache> {
900 UrlResponseDiskCache _impl; 933 UrlResponseDiskCache _impl;
901 934
902 _UrlResponseDiskCacheStubControl.fromEndpoint( 935 _UrlResponseDiskCacheStubControl.fromEndpoint(
903 core.MojoMessagePipeEndpoint endpoint, [UrlResponseDiskCache impl]) 936 core.MojoMessagePipeEndpoint endpoint, [UrlResponseDiskCache impl])
904 : super.fromEndpoint(endpoint, autoBegin: impl != null) { 937 : super.fromEndpoint(endpoint, autoBegin: impl != null) {
905 _impl = impl; 938 _impl = impl;
906 } 939 }
907 940
908 _UrlResponseDiskCacheStubControl.fromHandle( 941 _UrlResponseDiskCacheStubControl.fromHandle(
909 core.MojoHandle handle, [UrlResponseDiskCache impl]) 942 core.MojoHandle handle, [UrlResponseDiskCache impl])
910 : super.fromHandle(handle, autoBegin: impl != null) { 943 : super.fromHandle(handle, autoBegin: impl != null) {
911 _impl = impl; 944 _impl = impl;
912 } 945 }
913 946
914 _UrlResponseDiskCacheStubControl.unbound([this._impl]) : super.unbound(); 947 _UrlResponseDiskCacheStubControl.unbound([this._impl]) : super.unbound();
915 948
916 String get serviceName => UrlResponseDiskCache.serviceName; 949 String get serviceName => UrlResponseDiskCache.serviceName;
917 950
918 951
919 static UrlResponseDiskCacheGetResponseParams _urlResponseDiskCacheGetResponseP aramsFactory(url_response_mojom.UrlResponse response, List<int> filePath, List<i nt> cacheDirPath) { 952 Function _urlResponseDiskCacheGetResponseParamsResponder(
920 var result = new UrlResponseDiskCacheGetResponseParams(); 953 int requestId) {
921 result.response = response; 954 return (url_response_mojom.UrlResponse response, List<int> filePath, List<int> cacheDirPath) {
922 result.filePath = filePath; 955 var result = new UrlResponseDiskCacheGetResponseParams();
923 result.cacheDirPath = cacheDirPath; 956 result.response = response;
924 return result; 957 result.filePath = filePath;
958 result.cacheDirPath = cacheDirPath;
959 sendResponse(buildResponseWithId(
960 result,
961 _urlResponseDiskCacheMethodGetName,
962 requestId,
963 bindings.MessageHeader.kMessageIsResponse));
964 };
925 } 965 }
926 static UrlResponseDiskCacheUpdateAndGetResponseParams _urlResponseDiskCacheUpd ateAndGetResponseParamsFactory(List<int> filePath, List<int> cacheDirPath) { 966 Function _urlResponseDiskCacheUpdateAndGetResponseParamsResponder(
927 var result = new UrlResponseDiskCacheUpdateAndGetResponseParams(); 967 int requestId) {
928 result.filePath = filePath; 968 return (List<int> filePath, List<int> cacheDirPath) {
929 result.cacheDirPath = cacheDirPath; 969 var result = new UrlResponseDiskCacheUpdateAndGetResponseParams();
930 return result; 970 result.filePath = filePath;
971 result.cacheDirPath = cacheDirPath;
972 sendResponse(buildResponseWithId(
973 result,
974 _urlResponseDiskCacheMethodUpdateAndGetName,
975 requestId,
976 bindings.MessageHeader.kMessageIsResponse));
977 };
931 } 978 }
932 static UrlResponseDiskCacheUpdateAndGetExtractedResponseParams _urlResponseDis kCacheUpdateAndGetExtractedResponseParamsFactory(List<int> extractedDirPath, Lis t<int> cacheDirPath) { 979 Function _urlResponseDiskCacheUpdateAndGetExtractedResponseParamsResponder(
933 var result = new UrlResponseDiskCacheUpdateAndGetExtractedResponseParams(); 980 int requestId) {
934 result.extractedDirPath = extractedDirPath; 981 return (List<int> extractedDirPath, List<int> cacheDirPath) {
935 result.cacheDirPath = cacheDirPath; 982 var result = new UrlResponseDiskCacheUpdateAndGetExtractedResponseParams() ;
936 return result; 983 result.extractedDirPath = extractedDirPath;
984 result.cacheDirPath = cacheDirPath;
985 sendResponse(buildResponseWithId(
986 result,
987 _urlResponseDiskCacheMethodUpdateAndGetExtractedName,
988 requestId,
989 bindings.MessageHeader.kMessageIsResponse));
990 };
937 } 991 }
938 992
939 dynamic handleMessage(bindings.ServiceMessage message) { 993 void handleMessage(bindings.ServiceMessage message) {
940 if (bindings.ControlMessageHandler.isControlMessage(message)) { 994 if (bindings.ControlMessageHandler.isControlMessage(message)) {
941 return bindings.ControlMessageHandler.handleMessage(this, 995 bindings.ControlMessageHandler.handleMessage(
942 0, 996 this, 0, message);
943 message); 997 return;
944 } 998 }
945 if (_impl == null) { 999 if (_impl == null) {
946 throw new core.MojoApiError("$this has no implementation set"); 1000 throw new core.MojoApiError("$this has no implementation set");
947 } 1001 }
948 switch (message.header.type) { 1002 switch (message.header.type) {
949 case _urlResponseDiskCacheMethodGetName: 1003 case _urlResponseDiskCacheMethodGetName:
950 var params = _UrlResponseDiskCacheGetParams.deserialize( 1004 var params = _UrlResponseDiskCacheGetParams.deserialize(
951 message.payload); 1005 message.payload);
952 var response = _impl.get(params.url,_urlResponseDiskCacheGetResponsePara msFactory); 1006 _impl.get(params.url, _urlResponseDiskCacheGetResponseParamsResponder(me ssage.header.requestId));
953 if (response is Future) {
954 return response.then((response) {
955 if (response != null) {
956 return buildResponseWithId(
957 response,
958 _urlResponseDiskCacheMethodGetName,
959 message.header.requestId,
960 bindings.MessageHeader.kMessageIsResponse);
961 }
962 });
963 } else if (response != null) {
964 return buildResponseWithId(
965 response,
966 _urlResponseDiskCacheMethodGetName,
967 message.header.requestId,
968 bindings.MessageHeader.kMessageIsResponse);
969 }
970 break; 1007 break;
971 case _urlResponseDiskCacheMethodValidateName: 1008 case _urlResponseDiskCacheMethodValidateName:
972 var params = _UrlResponseDiskCacheValidateParams.deserialize( 1009 var params = _UrlResponseDiskCacheValidateParams.deserialize(
973 message.payload); 1010 message.payload);
974 _impl.validate(params.url); 1011 _impl.validate(params.url);
975 break; 1012 break;
976 case _urlResponseDiskCacheMethodUpdateName: 1013 case _urlResponseDiskCacheMethodUpdateName:
977 var params = _UrlResponseDiskCacheUpdateParams.deserialize( 1014 var params = _UrlResponseDiskCacheUpdateParams.deserialize(
978 message.payload); 1015 message.payload);
979 _impl.update(params.response); 1016 _impl.update(params.response);
980 break; 1017 break;
981 case _urlResponseDiskCacheMethodUpdateAndGetName: 1018 case _urlResponseDiskCacheMethodUpdateAndGetName:
982 var params = _UrlResponseDiskCacheUpdateAndGetParams.deserialize( 1019 var params = _UrlResponseDiskCacheUpdateAndGetParams.deserialize(
983 message.payload); 1020 message.payload);
984 var response = _impl.updateAndGet(params.response,_urlResponseDiskCacheU pdateAndGetResponseParamsFactory); 1021 _impl.updateAndGet(params.response, _urlResponseDiskCacheUpdateAndGetRes ponseParamsResponder(message.header.requestId));
985 if (response is Future) {
986 return response.then((response) {
987 if (response != null) {
988 return buildResponseWithId(
989 response,
990 _urlResponseDiskCacheMethodUpdateAndGetName,
991 message.header.requestId,
992 bindings.MessageHeader.kMessageIsResponse);
993 }
994 });
995 } else if (response != null) {
996 return buildResponseWithId(
997 response,
998 _urlResponseDiskCacheMethodUpdateAndGetName,
999 message.header.requestId,
1000 bindings.MessageHeader.kMessageIsResponse);
1001 }
1002 break; 1022 break;
1003 case _urlResponseDiskCacheMethodUpdateAndGetExtractedName: 1023 case _urlResponseDiskCacheMethodUpdateAndGetExtractedName:
1004 var params = _UrlResponseDiskCacheUpdateAndGetExtractedParams.deserializ e( 1024 var params = _UrlResponseDiskCacheUpdateAndGetExtractedParams.deserializ e(
1005 message.payload); 1025 message.payload);
1006 var response = _impl.updateAndGetExtracted(params.response,_urlResponseD iskCacheUpdateAndGetExtractedResponseParamsFactory); 1026 _impl.updateAndGetExtracted(params.response, _urlResponseDiskCacheUpdate AndGetExtractedResponseParamsResponder(message.header.requestId));
1007 if (response is Future) {
1008 return response.then((response) {
1009 if (response != null) {
1010 return buildResponseWithId(
1011 response,
1012 _urlResponseDiskCacheMethodUpdateAndGetExtractedName,
1013 message.header.requestId,
1014 bindings.MessageHeader.kMessageIsResponse);
1015 }
1016 });
1017 } else if (response != null) {
1018 return buildResponseWithId(
1019 response,
1020 _urlResponseDiskCacheMethodUpdateAndGetExtractedName,
1021 message.header.requestId,
1022 bindings.MessageHeader.kMessageIsResponse);
1023 }
1024 break; 1027 break;
1025 default: 1028 default:
1026 throw new bindings.MojoCodecError("Unexpected message name"); 1029 throw new bindings.MojoCodecError("Unexpected message name");
1027 break; 1030 break;
1028 } 1031 }
1029 return null;
1030 } 1032 }
1031 1033
1032 UrlResponseDiskCache get impl => _impl; 1034 UrlResponseDiskCache get impl => _impl;
1033 set impl(UrlResponseDiskCache d) { 1035 set impl(UrlResponseDiskCache d) {
1034 if (d == null) { 1036 if (d == null) {
1035 throw new core.MojoApiError("$this: Cannot set a null implementation"); 1037 throw new core.MojoApiError("$this: Cannot set a null implementation");
1036 } 1038 }
1037 if (isBound && (_impl == null)) { 1039 if (isBound && (_impl == null)) {
1038 beginHandlingEvents(); 1040 beginHandlingEvents();
1039 } 1041 }
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after
1073 core.MojoHandle handle, [UrlResponseDiskCache impl]) 1075 core.MojoHandle handle, [UrlResponseDiskCache impl])
1074 : super(new _UrlResponseDiskCacheStubControl.fromHandle(handle, impl)); 1076 : super(new _UrlResponseDiskCacheStubControl.fromHandle(handle, impl));
1075 1077
1076 static UrlResponseDiskCacheStub newFromEndpoint( 1078 static UrlResponseDiskCacheStub newFromEndpoint(
1077 core.MojoMessagePipeEndpoint endpoint) { 1079 core.MojoMessagePipeEndpoint endpoint) {
1078 assert(endpoint.setDescription("For UrlResponseDiskCacheStub")); 1080 assert(endpoint.setDescription("For UrlResponseDiskCacheStub"));
1079 return new UrlResponseDiskCacheStub.fromEndpoint(endpoint); 1081 return new UrlResponseDiskCacheStub.fromEndpoint(endpoint);
1080 } 1082 }
1081 1083
1082 1084
1083 dynamic get(String url,[Function responseFactory = null]) { 1085 void get(String url,void callback(url_response_mojom.UrlResponse response, Lis t<int> filePath, List<int> cacheDirPath)) {
1084 return impl.get(url,responseFactory); 1086 return impl.get(url,callback);
1085 } 1087 }
1086 void validate(String url) { 1088 void validate(String url) {
1087 return impl.validate(url); 1089 return impl.validate(url);
1088 } 1090 }
1089 void update(url_response_mojom.UrlResponse response) { 1091 void update(url_response_mojom.UrlResponse response) {
1090 return impl.update(response); 1092 return impl.update(response);
1091 } 1093 }
1092 dynamic updateAndGet(url_response_mojom.UrlResponse response,[Function respons eFactory = null]) { 1094 void updateAndGet(url_response_mojom.UrlResponse response,void callback(List<i nt> filePath, List<int> cacheDirPath)) {
1093 return impl.updateAndGet(response,responseFactory); 1095 return impl.updateAndGet(response,callback);
1094 } 1096 }
1095 dynamic updateAndGetExtracted(url_response_mojom.UrlResponse response,[Functio n responseFactory = null]) { 1097 void updateAndGetExtracted(url_response_mojom.UrlResponse response,void callba ck(List<int> extractedDirPath, List<int> cacheDirPath)) {
1096 return impl.updateAndGetExtracted(response,responseFactory); 1098 return impl.updateAndGetExtracted(response,callback);
1097 } 1099 }
1098 } 1100 }
1099 1101
1100 1102
1101 1103
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698