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 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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 Loading... |
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 |
OLD | NEW |