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_loader_mojom; | 4 library url_loader_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/network_error.mojom.dart' as network_error_mojom; | 9 import 'package:mojo/mojo/network_error.mojom.dart' as network_error_mojom; |
10 import 'package:mojo/mojo/url_request.mojom.dart' as url_request_mojom; | 10 import 'package:mojo/mojo/url_request.mojom.dart' as url_request_mojom; |
11 import 'package:mojo/mojo/url_response.mojom.dart' as url_response_mojom; | 11 import 'package:mojo/mojo/url_response.mojom.dart' as url_response_mojom; |
12 | 12 |
13 | 13 |
14 | 14 |
15 class UrlLoaderStatus extends bindings.Struct { | 15 class UrlLoaderStatus extends bindings.Struct { |
16 static const List<bindings.StructDataHeader> kVersions = const [ | 16 static const List<bindings.StructDataHeader> kVersions = const [ |
17 const bindings.StructDataHeader(24, 0) | 17 const bindings.StructDataHeader(24, 0) |
18 ]; | 18 ]; |
19 network_error_mojom.NetworkError error = null; | 19 network_error_mojom.NetworkError error = null; |
20 bool isLoading = false; | 20 bool isLoading = false; |
21 | 21 |
22 UrlLoaderStatus() : super(kVersions.last.size); | 22 UrlLoaderStatus() : super(kVersions.last.size); |
23 | 23 |
| 24 UrlLoaderStatus.init( |
| 25 network_error_mojom.NetworkError this.error, |
| 26 bool this.isLoading |
| 27 ) : super(kVersions.last.size); |
| 28 |
24 static UrlLoaderStatus deserialize(bindings.Message message) { | 29 static UrlLoaderStatus deserialize(bindings.Message message) { |
25 var decoder = new bindings.Decoder(message); | 30 var decoder = new bindings.Decoder(message); |
26 var result = decode(decoder); | 31 var result = decode(decoder); |
27 if (decoder.excessHandles != null) { | 32 if (decoder.excessHandles != null) { |
28 decoder.excessHandles.forEach((h) => h.close()); | 33 decoder.excessHandles.forEach((h) => h.close()); |
29 } | 34 } |
30 return result; | 35 return result; |
31 } | 36 } |
32 | 37 |
33 static UrlLoaderStatus decode(bindings.Decoder decoder0) { | 38 static UrlLoaderStatus decode(bindings.Decoder decoder0) { |
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
100 | 105 |
101 | 106 |
102 class _UrlLoaderStartParams extends bindings.Struct { | 107 class _UrlLoaderStartParams extends bindings.Struct { |
103 static const List<bindings.StructDataHeader> kVersions = const [ | 108 static const List<bindings.StructDataHeader> kVersions = const [ |
104 const bindings.StructDataHeader(16, 0) | 109 const bindings.StructDataHeader(16, 0) |
105 ]; | 110 ]; |
106 url_request_mojom.UrlRequest request = null; | 111 url_request_mojom.UrlRequest request = null; |
107 | 112 |
108 _UrlLoaderStartParams() : super(kVersions.last.size); | 113 _UrlLoaderStartParams() : super(kVersions.last.size); |
109 | 114 |
| 115 _UrlLoaderStartParams.init( |
| 116 url_request_mojom.UrlRequest this.request |
| 117 ) : super(kVersions.last.size); |
| 118 |
110 static _UrlLoaderStartParams deserialize(bindings.Message message) { | 119 static _UrlLoaderStartParams deserialize(bindings.Message message) { |
111 var decoder = new bindings.Decoder(message); | 120 var decoder = new bindings.Decoder(message); |
112 var result = decode(decoder); | 121 var result = decode(decoder); |
113 if (decoder.excessHandles != null) { | 122 if (decoder.excessHandles != null) { |
114 decoder.excessHandles.forEach((h) => h.close()); | 123 decoder.excessHandles.forEach((h) => h.close()); |
115 } | 124 } |
116 return result; | 125 return result; |
117 } | 126 } |
118 | 127 |
119 static _UrlLoaderStartParams decode(bindings.Decoder decoder0) { | 128 static _UrlLoaderStartParams decode(bindings.Decoder decoder0) { |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
172 | 181 |
173 | 182 |
174 class UrlLoaderStartResponseParams extends bindings.Struct { | 183 class UrlLoaderStartResponseParams extends bindings.Struct { |
175 static const List<bindings.StructDataHeader> kVersions = const [ | 184 static const List<bindings.StructDataHeader> kVersions = const [ |
176 const bindings.StructDataHeader(16, 0) | 185 const bindings.StructDataHeader(16, 0) |
177 ]; | 186 ]; |
178 url_response_mojom.UrlResponse response = null; | 187 url_response_mojom.UrlResponse response = null; |
179 | 188 |
180 UrlLoaderStartResponseParams() : super(kVersions.last.size); | 189 UrlLoaderStartResponseParams() : super(kVersions.last.size); |
181 | 190 |
| 191 UrlLoaderStartResponseParams.init( |
| 192 url_response_mojom.UrlResponse this.response |
| 193 ) : super(kVersions.last.size); |
| 194 |
182 static UrlLoaderStartResponseParams deserialize(bindings.Message message) { | 195 static UrlLoaderStartResponseParams deserialize(bindings.Message message) { |
183 var decoder = new bindings.Decoder(message); | 196 var decoder = new bindings.Decoder(message); |
184 var result = decode(decoder); | 197 var result = decode(decoder); |
185 if (decoder.excessHandles != null) { | 198 if (decoder.excessHandles != null) { |
186 decoder.excessHandles.forEach((h) => h.close()); | 199 decoder.excessHandles.forEach((h) => h.close()); |
187 } | 200 } |
188 return result; | 201 return result; |
189 } | 202 } |
190 | 203 |
191 static UrlLoaderStartResponseParams decode(bindings.Decoder decoder0) { | 204 static UrlLoaderStartResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
243 } | 256 } |
244 | 257 |
245 | 258 |
246 class _UrlLoaderFollowRedirectParams extends bindings.Struct { | 259 class _UrlLoaderFollowRedirectParams extends bindings.Struct { |
247 static const List<bindings.StructDataHeader> kVersions = const [ | 260 static const List<bindings.StructDataHeader> kVersions = const [ |
248 const bindings.StructDataHeader(8, 0) | 261 const bindings.StructDataHeader(8, 0) |
249 ]; | 262 ]; |
250 | 263 |
251 _UrlLoaderFollowRedirectParams() : super(kVersions.last.size); | 264 _UrlLoaderFollowRedirectParams() : super(kVersions.last.size); |
252 | 265 |
| 266 _UrlLoaderFollowRedirectParams.init( |
| 267 ) : super(kVersions.last.size); |
| 268 |
253 static _UrlLoaderFollowRedirectParams deserialize(bindings.Message message) { | 269 static _UrlLoaderFollowRedirectParams deserialize(bindings.Message message) { |
254 var decoder = new bindings.Decoder(message); | 270 var decoder = new bindings.Decoder(message); |
255 var result = decode(decoder); | 271 var result = decode(decoder); |
256 if (decoder.excessHandles != null) { | 272 if (decoder.excessHandles != null) { |
257 decoder.excessHandles.forEach((h) => h.close()); | 273 decoder.excessHandles.forEach((h) => h.close()); |
258 } | 274 } |
259 return result; | 275 return result; |
260 } | 276 } |
261 | 277 |
262 static _UrlLoaderFollowRedirectParams decode(bindings.Decoder decoder0) { | 278 static _UrlLoaderFollowRedirectParams decode(bindings.Decoder decoder0) { |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
302 | 318 |
303 | 319 |
304 class UrlLoaderFollowRedirectResponseParams extends bindings.Struct { | 320 class UrlLoaderFollowRedirectResponseParams extends bindings.Struct { |
305 static const List<bindings.StructDataHeader> kVersions = const [ | 321 static const List<bindings.StructDataHeader> kVersions = const [ |
306 const bindings.StructDataHeader(16, 0) | 322 const bindings.StructDataHeader(16, 0) |
307 ]; | 323 ]; |
308 url_response_mojom.UrlResponse response = null; | 324 url_response_mojom.UrlResponse response = null; |
309 | 325 |
310 UrlLoaderFollowRedirectResponseParams() : super(kVersions.last.size); | 326 UrlLoaderFollowRedirectResponseParams() : super(kVersions.last.size); |
311 | 327 |
| 328 UrlLoaderFollowRedirectResponseParams.init( |
| 329 url_response_mojom.UrlResponse this.response |
| 330 ) : super(kVersions.last.size); |
| 331 |
312 static UrlLoaderFollowRedirectResponseParams deserialize(bindings.Message mess
age) { | 332 static UrlLoaderFollowRedirectResponseParams deserialize(bindings.Message mess
age) { |
313 var decoder = new bindings.Decoder(message); | 333 var decoder = new bindings.Decoder(message); |
314 var result = decode(decoder); | 334 var result = decode(decoder); |
315 if (decoder.excessHandles != null) { | 335 if (decoder.excessHandles != null) { |
316 decoder.excessHandles.forEach((h) => h.close()); | 336 decoder.excessHandles.forEach((h) => h.close()); |
317 } | 337 } |
318 return result; | 338 return result; |
319 } | 339 } |
320 | 340 |
321 static UrlLoaderFollowRedirectResponseParams decode(bindings.Decoder decoder0)
{ | 341 static UrlLoaderFollowRedirectResponseParams decode(bindings.Decoder decoder0)
{ |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
373 } | 393 } |
374 | 394 |
375 | 395 |
376 class _UrlLoaderQueryStatusParams extends bindings.Struct { | 396 class _UrlLoaderQueryStatusParams extends bindings.Struct { |
377 static const List<bindings.StructDataHeader> kVersions = const [ | 397 static const List<bindings.StructDataHeader> kVersions = const [ |
378 const bindings.StructDataHeader(8, 0) | 398 const bindings.StructDataHeader(8, 0) |
379 ]; | 399 ]; |
380 | 400 |
381 _UrlLoaderQueryStatusParams() : super(kVersions.last.size); | 401 _UrlLoaderQueryStatusParams() : super(kVersions.last.size); |
382 | 402 |
| 403 _UrlLoaderQueryStatusParams.init( |
| 404 ) : super(kVersions.last.size); |
| 405 |
383 static _UrlLoaderQueryStatusParams deserialize(bindings.Message message) { | 406 static _UrlLoaderQueryStatusParams deserialize(bindings.Message message) { |
384 var decoder = new bindings.Decoder(message); | 407 var decoder = new bindings.Decoder(message); |
385 var result = decode(decoder); | 408 var result = decode(decoder); |
386 if (decoder.excessHandles != null) { | 409 if (decoder.excessHandles != null) { |
387 decoder.excessHandles.forEach((h) => h.close()); | 410 decoder.excessHandles.forEach((h) => h.close()); |
388 } | 411 } |
389 return result; | 412 return result; |
390 } | 413 } |
391 | 414 |
392 static _UrlLoaderQueryStatusParams decode(bindings.Decoder decoder0) { | 415 static _UrlLoaderQueryStatusParams decode(bindings.Decoder decoder0) { |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
432 | 455 |
433 | 456 |
434 class UrlLoaderQueryStatusResponseParams extends bindings.Struct { | 457 class UrlLoaderQueryStatusResponseParams extends bindings.Struct { |
435 static const List<bindings.StructDataHeader> kVersions = const [ | 458 static const List<bindings.StructDataHeader> kVersions = const [ |
436 const bindings.StructDataHeader(16, 0) | 459 const bindings.StructDataHeader(16, 0) |
437 ]; | 460 ]; |
438 UrlLoaderStatus status = null; | 461 UrlLoaderStatus status = null; |
439 | 462 |
440 UrlLoaderQueryStatusResponseParams() : super(kVersions.last.size); | 463 UrlLoaderQueryStatusResponseParams() : super(kVersions.last.size); |
441 | 464 |
| 465 UrlLoaderQueryStatusResponseParams.init( |
| 466 UrlLoaderStatus this.status |
| 467 ) : super(kVersions.last.size); |
| 468 |
442 static UrlLoaderQueryStatusResponseParams deserialize(bindings.Message message
) { | 469 static UrlLoaderQueryStatusResponseParams deserialize(bindings.Message message
) { |
443 var decoder = new bindings.Decoder(message); | 470 var decoder = new bindings.Decoder(message); |
444 var result = decode(decoder); | 471 var result = decode(decoder); |
445 if (decoder.excessHandles != null) { | 472 if (decoder.excessHandles != null) { |
446 decoder.excessHandles.forEach((h) => h.close()); | 473 decoder.excessHandles.forEach((h) => h.close()); |
447 } | 474 } |
448 return result; | 475 return result; |
449 } | 476 } |
450 | 477 |
451 static UrlLoaderQueryStatusResponseParams decode(bindings.Decoder decoder0) { | 478 static UrlLoaderQueryStatusResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
501 map["status"] = status; | 528 map["status"] = status; |
502 return map; | 529 return map; |
503 } | 530 } |
504 } | 531 } |
505 | 532 |
506 const int _urlLoaderMethodStartName = 0; | 533 const int _urlLoaderMethodStartName = 0; |
507 const int _urlLoaderMethodFollowRedirectName = 1; | 534 const int _urlLoaderMethodFollowRedirectName = 1; |
508 const int _urlLoaderMethodQueryStatusName = 2; | 535 const int _urlLoaderMethodQueryStatusName = 2; |
509 | 536 |
510 class _UrlLoaderServiceDescription implements service_describer.ServiceDescripti
on { | 537 class _UrlLoaderServiceDescription implements service_describer.ServiceDescripti
on { |
511 dynamic getTopLevelInterface([Function responseFactory]) => | 538 void getTopLevelInterface(Function responder) { |
512 responseFactory(null); | 539 responder(null); |
| 540 } |
513 | 541 |
514 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 542 void getTypeDefinition(String typeKey, Function responder) { |
515 responseFactory(null); | 543 responder(null); |
| 544 } |
516 | 545 |
517 dynamic getAllTypeDefinitions([Function responseFactory]) => | 546 void getAllTypeDefinitions(Function responder) { |
518 responseFactory(null); | 547 responder(null); |
| 548 } |
519 } | 549 } |
520 | 550 |
521 abstract class UrlLoader { | 551 abstract class UrlLoader { |
522 static const String serviceName = null; | 552 static const String serviceName = null; |
523 | 553 |
524 static service_describer.ServiceDescription _cachedServiceDescription; | 554 static service_describer.ServiceDescription _cachedServiceDescription; |
525 static service_describer.ServiceDescription get serviceDescription { | 555 static service_describer.ServiceDescription get serviceDescription { |
526 if (_cachedServiceDescription == null) { | 556 if (_cachedServiceDescription == null) { |
527 _cachedServiceDescription = new _UrlLoaderServiceDescription(); | 557 _cachedServiceDescription = new _UrlLoaderServiceDescription(); |
528 } | 558 } |
529 return _cachedServiceDescription; | 559 return _cachedServiceDescription; |
530 } | 560 } |
531 | 561 |
532 static UrlLoaderProxy connectToService( | 562 static UrlLoaderProxy connectToService( |
533 bindings.ServiceConnector s, String url, [String serviceName]) { | 563 bindings.ServiceConnector s, String url, [String serviceName]) { |
534 UrlLoaderProxy p = new UrlLoaderProxy.unbound(); | 564 UrlLoaderProxy p = new UrlLoaderProxy.unbound(); |
535 String name = serviceName ?? UrlLoader.serviceName; | 565 String name = serviceName ?? UrlLoader.serviceName; |
536 if ((name == null) || name.isEmpty) { | 566 if ((name == null) || name.isEmpty) { |
537 throw new core.MojoApiError( | 567 throw new core.MojoApiError( |
538 "If an interface has no ServiceName, then one must be provided."); | 568 "If an interface has no ServiceName, then one must be provided."); |
539 } | 569 } |
540 s.connectToService(url, p, name); | 570 s.connectToService(url, p, name); |
541 return p; | 571 return p; |
542 } | 572 } |
543 dynamic start(url_request_mojom.UrlRequest request,[Function responseFactory =
null]); | 573 void start(url_request_mojom.UrlRequest request,void callback(url_response_moj
om.UrlResponse response)); |
544 dynamic followRedirect([Function responseFactory = null]); | 574 void followRedirect(void callback(url_response_mojom.UrlResponse response)); |
545 dynamic queryStatus([Function responseFactory = null]); | 575 void queryStatus(void callback(UrlLoaderStatus status)); |
546 } | 576 } |
547 | 577 |
548 abstract class UrlLoaderInterface | 578 abstract class UrlLoaderInterface |
549 implements bindings.MojoInterface<UrlLoader>, | 579 implements bindings.MojoInterface<UrlLoader>, |
550 UrlLoader { | 580 UrlLoader { |
551 factory UrlLoaderInterface([UrlLoader impl]) => | 581 factory UrlLoaderInterface([UrlLoader impl]) => |
552 new UrlLoaderStub.unbound(impl); | 582 new UrlLoaderStub.unbound(impl); |
553 | 583 |
554 factory UrlLoaderInterface.fromEndpoint( | 584 factory UrlLoaderInterface.fromEndpoint( |
555 core.MojoMessagePipeEndpoint endpoint, | 585 core.MojoMessagePipeEndpoint endpoint, |
(...skipping 29 matching lines...) Expand all Loading... |
585 | 615 |
586 void handleResponse(bindings.ServiceMessage message) { | 616 void handleResponse(bindings.ServiceMessage message) { |
587 switch (message.header.type) { | 617 switch (message.header.type) { |
588 case _urlLoaderMethodStartName: | 618 case _urlLoaderMethodStartName: |
589 var r = UrlLoaderStartResponseParams.deserialize( | 619 var r = UrlLoaderStartResponseParams.deserialize( |
590 message.payload); | 620 message.payload); |
591 if (!message.header.hasRequestId) { | 621 if (!message.header.hasRequestId) { |
592 proxyError("Expected a message with a valid request Id."); | 622 proxyError("Expected a message with a valid request Id."); |
593 return; | 623 return; |
594 } | 624 } |
595 Completer c = completerMap[message.header.requestId]; | 625 Function callback = callbackMap[message.header.requestId]; |
596 if (c == null) { | 626 if (callback == null) { |
597 proxyError( | 627 proxyError( |
598 "Message had unknown request Id: ${message.header.requestId}"); | 628 "Message had unknown request Id: ${message.header.requestId}"); |
599 return; | 629 return; |
600 } | 630 } |
601 completerMap.remove(message.header.requestId); | 631 callbackMap.remove(message.header.requestId); |
602 if (c.isCompleted) { | 632 callback(r.response ); |
603 proxyError("Response completer already completed"); | |
604 return; | |
605 } | |
606 c.complete(r); | |
607 break; | 633 break; |
608 case _urlLoaderMethodFollowRedirectName: | 634 case _urlLoaderMethodFollowRedirectName: |
609 var r = UrlLoaderFollowRedirectResponseParams.deserialize( | 635 var r = UrlLoaderFollowRedirectResponseParams.deserialize( |
610 message.payload); | 636 message.payload); |
611 if (!message.header.hasRequestId) { | 637 if (!message.header.hasRequestId) { |
612 proxyError("Expected a message with a valid request Id."); | 638 proxyError("Expected a message with a valid request Id."); |
613 return; | 639 return; |
614 } | 640 } |
615 Completer c = completerMap[message.header.requestId]; | 641 Function callback = callbackMap[message.header.requestId]; |
616 if (c == null) { | 642 if (callback == null) { |
617 proxyError( | 643 proxyError( |
618 "Message had unknown request Id: ${message.header.requestId}"); | 644 "Message had unknown request Id: ${message.header.requestId}"); |
619 return; | 645 return; |
620 } | 646 } |
621 completerMap.remove(message.header.requestId); | 647 callbackMap.remove(message.header.requestId); |
622 if (c.isCompleted) { | 648 callback(r.response ); |
623 proxyError("Response completer already completed"); | |
624 return; | |
625 } | |
626 c.complete(r); | |
627 break; | 649 break; |
628 case _urlLoaderMethodQueryStatusName: | 650 case _urlLoaderMethodQueryStatusName: |
629 var r = UrlLoaderQueryStatusResponseParams.deserialize( | 651 var r = UrlLoaderQueryStatusResponseParams.deserialize( |
630 message.payload); | 652 message.payload); |
631 if (!message.header.hasRequestId) { | 653 if (!message.header.hasRequestId) { |
632 proxyError("Expected a message with a valid request Id."); | 654 proxyError("Expected a message with a valid request Id."); |
633 return; | 655 return; |
634 } | 656 } |
635 Completer c = completerMap[message.header.requestId]; | 657 Function callback = callbackMap[message.header.requestId]; |
636 if (c == null) { | 658 if (callback == null) { |
637 proxyError( | 659 proxyError( |
638 "Message had unknown request Id: ${message.header.requestId}"); | 660 "Message had unknown request Id: ${message.header.requestId}"); |
639 return; | 661 return; |
640 } | 662 } |
641 completerMap.remove(message.header.requestId); | 663 callbackMap.remove(message.header.requestId); |
642 if (c.isCompleted) { | 664 callback(r.status ); |
643 proxyError("Response completer already completed"); | |
644 return; | |
645 } | |
646 c.complete(r); | |
647 break; | 665 break; |
648 default: | 666 default: |
649 proxyError("Unexpected message type: ${message.header.type}"); | 667 proxyError("Unexpected message type: ${message.header.type}"); |
650 close(immediate: true); | 668 close(immediate: true); |
651 break; | 669 break; |
652 } | 670 } |
653 } | 671 } |
654 | 672 |
655 @override | 673 @override |
656 String toString() { | 674 String toString() { |
(...skipping 24 matching lines...) Expand all Loading... |
681 return newMockedProxy; | 699 return newMockedProxy; |
682 } | 700 } |
683 | 701 |
684 static UrlLoaderProxy newFromEndpoint( | 702 static UrlLoaderProxy newFromEndpoint( |
685 core.MojoMessagePipeEndpoint endpoint) { | 703 core.MojoMessagePipeEndpoint endpoint) { |
686 assert(endpoint.setDescription("For UrlLoaderProxy")); | 704 assert(endpoint.setDescription("For UrlLoaderProxy")); |
687 return new UrlLoaderProxy.fromEndpoint(endpoint); | 705 return new UrlLoaderProxy.fromEndpoint(endpoint); |
688 } | 706 } |
689 | 707 |
690 | 708 |
691 dynamic start(url_request_mojom.UrlRequest request,[Function responseFactory =
null]) { | 709 void start(url_request_mojom.UrlRequest request,void callback(url_response_moj
om.UrlResponse response)) { |
692 if (impl != null) { | 710 if (impl != null) { |
693 return new Future(() => impl.start(request,_UrlLoaderStubControl._urlLoade
rStartResponseParamsFactory)); | 711 impl.start(request,callback); |
| 712 return; |
694 } | 713 } |
695 var params = new _UrlLoaderStartParams(); | 714 var params = new _UrlLoaderStartParams(); |
696 params.request = request; | 715 params.request = request; |
697 return ctrl.sendMessageWithRequestId( | 716 ctrl.sendMessageWithRequestId( |
698 params, | 717 params, |
699 _urlLoaderMethodStartName, | 718 _urlLoaderMethodStartName, |
700 -1, | 719 -1, |
701 bindings.MessageHeader.kMessageExpectsResponse); | 720 bindings.MessageHeader.kMessageExpectsResponse, |
| 721 callback); |
702 } | 722 } |
703 dynamic followRedirect([Function responseFactory = null]) { | 723 void followRedirect(void callback(url_response_mojom.UrlResponse response)) { |
704 if (impl != null) { | 724 if (impl != null) { |
705 return new Future(() => impl.followRedirect(_UrlLoaderStubControl._urlLoad
erFollowRedirectResponseParamsFactory)); | 725 impl.followRedirect(callback); |
| 726 return; |
706 } | 727 } |
707 var params = new _UrlLoaderFollowRedirectParams(); | 728 var params = new _UrlLoaderFollowRedirectParams(); |
708 return ctrl.sendMessageWithRequestId( | 729 ctrl.sendMessageWithRequestId( |
709 params, | 730 params, |
710 _urlLoaderMethodFollowRedirectName, | 731 _urlLoaderMethodFollowRedirectName, |
711 -1, | 732 -1, |
712 bindings.MessageHeader.kMessageExpectsResponse); | 733 bindings.MessageHeader.kMessageExpectsResponse, |
| 734 callback); |
713 } | 735 } |
714 dynamic queryStatus([Function responseFactory = null]) { | 736 void queryStatus(void callback(UrlLoaderStatus status)) { |
715 if (impl != null) { | 737 if (impl != null) { |
716 return new Future(() => impl.queryStatus(_UrlLoaderStubControl._urlLoaderQ
ueryStatusResponseParamsFactory)); | 738 impl.queryStatus(callback); |
| 739 return; |
717 } | 740 } |
718 var params = new _UrlLoaderQueryStatusParams(); | 741 var params = new _UrlLoaderQueryStatusParams(); |
719 return ctrl.sendMessageWithRequestId( | 742 ctrl.sendMessageWithRequestId( |
720 params, | 743 params, |
721 _urlLoaderMethodQueryStatusName, | 744 _urlLoaderMethodQueryStatusName, |
722 -1, | 745 -1, |
723 bindings.MessageHeader.kMessageExpectsResponse); | 746 bindings.MessageHeader.kMessageExpectsResponse, |
| 747 callback); |
724 } | 748 } |
725 } | 749 } |
726 | 750 |
727 class _UrlLoaderStubControl | 751 class _UrlLoaderStubControl |
728 extends bindings.StubMessageHandler | 752 extends bindings.StubMessageHandler |
729 implements bindings.StubControl<UrlLoader> { | 753 implements bindings.StubControl<UrlLoader> { |
730 UrlLoader _impl; | 754 UrlLoader _impl; |
731 | 755 |
732 _UrlLoaderStubControl.fromEndpoint( | 756 _UrlLoaderStubControl.fromEndpoint( |
733 core.MojoMessagePipeEndpoint endpoint, [UrlLoader impl]) | 757 core.MojoMessagePipeEndpoint endpoint, [UrlLoader impl]) |
734 : super.fromEndpoint(endpoint, autoBegin: impl != null) { | 758 : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
735 _impl = impl; | 759 _impl = impl; |
736 } | 760 } |
737 | 761 |
738 _UrlLoaderStubControl.fromHandle( | 762 _UrlLoaderStubControl.fromHandle( |
739 core.MojoHandle handle, [UrlLoader impl]) | 763 core.MojoHandle handle, [UrlLoader impl]) |
740 : super.fromHandle(handle, autoBegin: impl != null) { | 764 : super.fromHandle(handle, autoBegin: impl != null) { |
741 _impl = impl; | 765 _impl = impl; |
742 } | 766 } |
743 | 767 |
744 _UrlLoaderStubControl.unbound([this._impl]) : super.unbound(); | 768 _UrlLoaderStubControl.unbound([this._impl]) : super.unbound(); |
745 | 769 |
746 String get serviceName => UrlLoader.serviceName; | 770 String get serviceName => UrlLoader.serviceName; |
747 | 771 |
748 | 772 |
749 static UrlLoaderStartResponseParams _urlLoaderStartResponseParamsFactory(url_r
esponse_mojom.UrlResponse response) { | 773 Function _urlLoaderStartResponseParamsResponder( |
750 var result = new UrlLoaderStartResponseParams(); | 774 int requestId) { |
751 result.response = response; | 775 return (url_response_mojom.UrlResponse response) { |
752 return result; | 776 var result = new UrlLoaderStartResponseParams(); |
| 777 result.response = response; |
| 778 sendResponse(buildResponseWithId( |
| 779 result, |
| 780 _urlLoaderMethodStartName, |
| 781 requestId, |
| 782 bindings.MessageHeader.kMessageIsResponse)); |
| 783 }; |
753 } | 784 } |
754 static UrlLoaderFollowRedirectResponseParams _urlLoaderFollowRedirectResponseP
aramsFactory(url_response_mojom.UrlResponse response) { | 785 Function _urlLoaderFollowRedirectResponseParamsResponder( |
755 var result = new UrlLoaderFollowRedirectResponseParams(); | 786 int requestId) { |
756 result.response = response; | 787 return (url_response_mojom.UrlResponse response) { |
757 return result; | 788 var result = new UrlLoaderFollowRedirectResponseParams(); |
| 789 result.response = response; |
| 790 sendResponse(buildResponseWithId( |
| 791 result, |
| 792 _urlLoaderMethodFollowRedirectName, |
| 793 requestId, |
| 794 bindings.MessageHeader.kMessageIsResponse)); |
| 795 }; |
758 } | 796 } |
759 static UrlLoaderQueryStatusResponseParams _urlLoaderQueryStatusResponseParamsF
actory(UrlLoaderStatus status) { | 797 Function _urlLoaderQueryStatusResponseParamsResponder( |
760 var result = new UrlLoaderQueryStatusResponseParams(); | 798 int requestId) { |
761 result.status = status; | 799 return (UrlLoaderStatus status) { |
762 return result; | 800 var result = new UrlLoaderQueryStatusResponseParams(); |
| 801 result.status = status; |
| 802 sendResponse(buildResponseWithId( |
| 803 result, |
| 804 _urlLoaderMethodQueryStatusName, |
| 805 requestId, |
| 806 bindings.MessageHeader.kMessageIsResponse)); |
| 807 }; |
763 } | 808 } |
764 | 809 |
765 dynamic handleMessage(bindings.ServiceMessage message) { | 810 void handleMessage(bindings.ServiceMessage message) { |
766 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 811 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
767 return bindings.ControlMessageHandler.handleMessage(this, | 812 bindings.ControlMessageHandler.handleMessage( |
768 0, | 813 this, 0, message); |
769 message); | 814 return; |
770 } | 815 } |
771 if (_impl == null) { | 816 if (_impl == null) { |
772 throw new core.MojoApiError("$this has no implementation set"); | 817 throw new core.MojoApiError("$this has no implementation set"); |
773 } | 818 } |
774 switch (message.header.type) { | 819 switch (message.header.type) { |
775 case _urlLoaderMethodStartName: | 820 case _urlLoaderMethodStartName: |
776 var params = _UrlLoaderStartParams.deserialize( | 821 var params = _UrlLoaderStartParams.deserialize( |
777 message.payload); | 822 message.payload); |
778 var response = _impl.start(params.request,_urlLoaderStartResponseParamsF
actory); | 823 _impl.start(params.request, _urlLoaderStartResponseParamsResponder(messa
ge.header.requestId)); |
779 if (response is Future) { | |
780 return response.then((response) { | |
781 if (response != null) { | |
782 return buildResponseWithId( | |
783 response, | |
784 _urlLoaderMethodStartName, | |
785 message.header.requestId, | |
786 bindings.MessageHeader.kMessageIsResponse); | |
787 } | |
788 }); | |
789 } else if (response != null) { | |
790 return buildResponseWithId( | |
791 response, | |
792 _urlLoaderMethodStartName, | |
793 message.header.requestId, | |
794 bindings.MessageHeader.kMessageIsResponse); | |
795 } | |
796 break; | 824 break; |
797 case _urlLoaderMethodFollowRedirectName: | 825 case _urlLoaderMethodFollowRedirectName: |
798 var response = _impl.followRedirect(_urlLoaderFollowRedirectResponsePara
msFactory); | 826 _impl.followRedirect(_urlLoaderFollowRedirectResponseParamsResponder(mes
sage.header.requestId)); |
799 if (response is Future) { | |
800 return response.then((response) { | |
801 if (response != null) { | |
802 return buildResponseWithId( | |
803 response, | |
804 _urlLoaderMethodFollowRedirectName, | |
805 message.header.requestId, | |
806 bindings.MessageHeader.kMessageIsResponse); | |
807 } | |
808 }); | |
809 } else if (response != null) { | |
810 return buildResponseWithId( | |
811 response, | |
812 _urlLoaderMethodFollowRedirectName, | |
813 message.header.requestId, | |
814 bindings.MessageHeader.kMessageIsResponse); | |
815 } | |
816 break; | 827 break; |
817 case _urlLoaderMethodQueryStatusName: | 828 case _urlLoaderMethodQueryStatusName: |
818 var response = _impl.queryStatus(_urlLoaderQueryStatusResponseParamsFact
ory); | 829 _impl.queryStatus(_urlLoaderQueryStatusResponseParamsResponder(message.h
eader.requestId)); |
819 if (response is Future) { | |
820 return response.then((response) { | |
821 if (response != null) { | |
822 return buildResponseWithId( | |
823 response, | |
824 _urlLoaderMethodQueryStatusName, | |
825 message.header.requestId, | |
826 bindings.MessageHeader.kMessageIsResponse); | |
827 } | |
828 }); | |
829 } else if (response != null) { | |
830 return buildResponseWithId( | |
831 response, | |
832 _urlLoaderMethodQueryStatusName, | |
833 message.header.requestId, | |
834 bindings.MessageHeader.kMessageIsResponse); | |
835 } | |
836 break; | 830 break; |
837 default: | 831 default: |
838 throw new bindings.MojoCodecError("Unexpected message name"); | 832 throw new bindings.MojoCodecError("Unexpected message name"); |
839 break; | 833 break; |
840 } | 834 } |
841 return null; | |
842 } | 835 } |
843 | 836 |
844 UrlLoader get impl => _impl; | 837 UrlLoader get impl => _impl; |
845 set impl(UrlLoader d) { | 838 set impl(UrlLoader d) { |
846 if (d == null) { | 839 if (d == null) { |
847 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 840 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
848 } | 841 } |
849 if (isBound && (_impl == null)) { | 842 if (isBound && (_impl == null)) { |
850 beginHandlingEvents(); | 843 beginHandlingEvents(); |
851 } | 844 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
885 core.MojoHandle handle, [UrlLoader impl]) | 878 core.MojoHandle handle, [UrlLoader impl]) |
886 : super(new _UrlLoaderStubControl.fromHandle(handle, impl)); | 879 : super(new _UrlLoaderStubControl.fromHandle(handle, impl)); |
887 | 880 |
888 static UrlLoaderStub newFromEndpoint( | 881 static UrlLoaderStub newFromEndpoint( |
889 core.MojoMessagePipeEndpoint endpoint) { | 882 core.MojoMessagePipeEndpoint endpoint) { |
890 assert(endpoint.setDescription("For UrlLoaderStub")); | 883 assert(endpoint.setDescription("For UrlLoaderStub")); |
891 return new UrlLoaderStub.fromEndpoint(endpoint); | 884 return new UrlLoaderStub.fromEndpoint(endpoint); |
892 } | 885 } |
893 | 886 |
894 | 887 |
895 dynamic start(url_request_mojom.UrlRequest request,[Function responseFactory =
null]) { | 888 void start(url_request_mojom.UrlRequest request,void callback(url_response_moj
om.UrlResponse response)) { |
896 return impl.start(request,responseFactory); | 889 return impl.start(request,callback); |
897 } | 890 } |
898 dynamic followRedirect([Function responseFactory = null]) { | 891 void followRedirect(void callback(url_response_mojom.UrlResponse response)) { |
899 return impl.followRedirect(responseFactory); | 892 return impl.followRedirect(callback); |
900 } | 893 } |
901 dynamic queryStatus([Function responseFactory = null]) { | 894 void queryStatus(void callback(UrlLoaderStatus status)) { |
902 return impl.queryStatus(responseFactory); | 895 return impl.queryStatus(callback); |
903 } | 896 } |
904 } | 897 } |
905 | 898 |
906 | 899 |
907 | 900 |
OLD | NEW |