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 media_transport_mojom; | 4 library media_transport_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 | 9 |
10 | 10 |
11 | 11 |
12 class MediaPacketRegion extends bindings.Struct { | 12 class MediaPacketRegion extends bindings.Struct { |
13 static const List<bindings.StructDataHeader> kVersions = const [ | 13 static const List<bindings.StructDataHeader> kVersions = const [ |
14 const bindings.StructDataHeader(24, 0) | 14 const bindings.StructDataHeader(24, 0) |
15 ]; | 15 ]; |
16 int offset = 0; | 16 int offset = 0; |
17 int length = 0; | 17 int length = 0; |
18 | 18 |
19 MediaPacketRegion() : super(kVersions.last.size); | 19 MediaPacketRegion() : super(kVersions.last.size); |
20 | 20 |
| 21 MediaPacketRegion.init( |
| 22 int this.offset, |
| 23 int this.length |
| 24 ) : super(kVersions.last.size); |
| 25 |
21 static MediaPacketRegion deserialize(bindings.Message message) { | 26 static MediaPacketRegion deserialize(bindings.Message message) { |
22 var decoder = new bindings.Decoder(message); | 27 var decoder = new bindings.Decoder(message); |
23 var result = decode(decoder); | 28 var result = decode(decoder); |
24 if (decoder.excessHandles != null) { | 29 if (decoder.excessHandles != null) { |
25 decoder.excessHandles.forEach((h) => h.close()); | 30 decoder.excessHandles.forEach((h) => h.close()); |
26 } | 31 } |
27 return result; | 32 return result; |
28 } | 33 } |
29 | 34 |
30 static MediaPacketRegion decode(bindings.Decoder decoder0) { | 35 static MediaPacketRegion decode(bindings.Decoder decoder0) { |
(...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
100 const bindings.StructDataHeader(40, 0) | 105 const bindings.StructDataHeader(40, 0) |
101 ]; | 106 ]; |
102 static const int kNoTimestamp = 9223372036854775807; | 107 static const int kNoTimestamp = 9223372036854775807; |
103 int pts = 9223372036854775807; | 108 int pts = 9223372036854775807; |
104 bool endOfStream = false; | 109 bool endOfStream = false; |
105 MediaPacketRegion payload = null; | 110 MediaPacketRegion payload = null; |
106 List<MediaPacketRegion> extraPayload = null; | 111 List<MediaPacketRegion> extraPayload = null; |
107 | 112 |
108 MediaPacket() : super(kVersions.last.size); | 113 MediaPacket() : super(kVersions.last.size); |
109 | 114 |
| 115 MediaPacket.init( |
| 116 int this.pts, |
| 117 bool this.endOfStream, |
| 118 MediaPacketRegion this.payload, |
| 119 List<MediaPacketRegion> this.extraPayload |
| 120 ) : super(kVersions.last.size); |
| 121 |
110 static MediaPacket deserialize(bindings.Message message) { | 122 static MediaPacket deserialize(bindings.Message message) { |
111 var decoder = new bindings.Decoder(message); | 123 var decoder = new bindings.Decoder(message); |
112 var result = decode(decoder); | 124 var result = decode(decoder); |
113 if (decoder.excessHandles != null) { | 125 if (decoder.excessHandles != null) { |
114 decoder.excessHandles.forEach((h) => h.close()); | 126 decoder.excessHandles.forEach((h) => h.close()); |
115 } | 127 } |
116 return result; | 128 return result; |
117 } | 129 } |
118 | 130 |
119 static MediaPacket decode(bindings.Decoder decoder0) { | 131 static MediaPacket decode(bindings.Decoder decoder0) { |
(...skipping 110 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
230 | 242 |
231 | 243 |
232 class _MediaProducerConnectParams extends bindings.Struct { | 244 class _MediaProducerConnectParams extends bindings.Struct { |
233 static const List<bindings.StructDataHeader> kVersions = const [ | 245 static const List<bindings.StructDataHeader> kVersions = const [ |
234 const bindings.StructDataHeader(16, 0) | 246 const bindings.StructDataHeader(16, 0) |
235 ]; | 247 ]; |
236 MediaConsumerInterface consumer = null; | 248 MediaConsumerInterface consumer = null; |
237 | 249 |
238 _MediaProducerConnectParams() : super(kVersions.last.size); | 250 _MediaProducerConnectParams() : super(kVersions.last.size); |
239 | 251 |
| 252 _MediaProducerConnectParams.init( |
| 253 MediaConsumerInterface this.consumer |
| 254 ) : super(kVersions.last.size); |
| 255 |
240 static _MediaProducerConnectParams deserialize(bindings.Message message) { | 256 static _MediaProducerConnectParams deserialize(bindings.Message message) { |
241 var decoder = new bindings.Decoder(message); | 257 var decoder = new bindings.Decoder(message); |
242 var result = decode(decoder); | 258 var result = decode(decoder); |
243 if (decoder.excessHandles != null) { | 259 if (decoder.excessHandles != null) { |
244 decoder.excessHandles.forEach((h) => h.close()); | 260 decoder.excessHandles.forEach((h) => h.close()); |
245 } | 261 } |
246 return result; | 262 return result; |
247 } | 263 } |
248 | 264 |
249 static _MediaProducerConnectParams decode(bindings.Decoder decoder0) { | 265 static _MediaProducerConnectParams decode(bindings.Decoder decoder0) { |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
300 } | 316 } |
301 | 317 |
302 | 318 |
303 class MediaProducerConnectResponseParams extends bindings.Struct { | 319 class MediaProducerConnectResponseParams extends bindings.Struct { |
304 static const List<bindings.StructDataHeader> kVersions = const [ | 320 static const List<bindings.StructDataHeader> kVersions = const [ |
305 const bindings.StructDataHeader(8, 0) | 321 const bindings.StructDataHeader(8, 0) |
306 ]; | 322 ]; |
307 | 323 |
308 MediaProducerConnectResponseParams() : super(kVersions.last.size); | 324 MediaProducerConnectResponseParams() : super(kVersions.last.size); |
309 | 325 |
| 326 MediaProducerConnectResponseParams.init( |
| 327 ) : super(kVersions.last.size); |
| 328 |
310 static MediaProducerConnectResponseParams deserialize(bindings.Message message
) { | 329 static MediaProducerConnectResponseParams deserialize(bindings.Message message
) { |
311 var decoder = new bindings.Decoder(message); | 330 var decoder = new bindings.Decoder(message); |
312 var result = decode(decoder); | 331 var result = decode(decoder); |
313 if (decoder.excessHandles != null) { | 332 if (decoder.excessHandles != null) { |
314 decoder.excessHandles.forEach((h) => h.close()); | 333 decoder.excessHandles.forEach((h) => h.close()); |
315 } | 334 } |
316 return result; | 335 return result; |
317 } | 336 } |
318 | 337 |
319 static MediaProducerConnectResponseParams decode(bindings.Decoder decoder0) { | 338 static MediaProducerConnectResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
358 } | 377 } |
359 | 378 |
360 | 379 |
361 class _MediaProducerDisconnectParams extends bindings.Struct { | 380 class _MediaProducerDisconnectParams extends bindings.Struct { |
362 static const List<bindings.StructDataHeader> kVersions = const [ | 381 static const List<bindings.StructDataHeader> kVersions = const [ |
363 const bindings.StructDataHeader(8, 0) | 382 const bindings.StructDataHeader(8, 0) |
364 ]; | 383 ]; |
365 | 384 |
366 _MediaProducerDisconnectParams() : super(kVersions.last.size); | 385 _MediaProducerDisconnectParams() : super(kVersions.last.size); |
367 | 386 |
| 387 _MediaProducerDisconnectParams.init( |
| 388 ) : super(kVersions.last.size); |
| 389 |
368 static _MediaProducerDisconnectParams deserialize(bindings.Message message) { | 390 static _MediaProducerDisconnectParams deserialize(bindings.Message message) { |
369 var decoder = new bindings.Decoder(message); | 391 var decoder = new bindings.Decoder(message); |
370 var result = decode(decoder); | 392 var result = decode(decoder); |
371 if (decoder.excessHandles != null) { | 393 if (decoder.excessHandles != null) { |
372 decoder.excessHandles.forEach((h) => h.close()); | 394 decoder.excessHandles.forEach((h) => h.close()); |
373 } | 395 } |
374 return result; | 396 return result; |
375 } | 397 } |
376 | 398 |
377 static _MediaProducerDisconnectParams decode(bindings.Decoder decoder0) { | 399 static _MediaProducerDisconnectParams decode(bindings.Decoder decoder0) { |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
416 } | 438 } |
417 | 439 |
418 | 440 |
419 class _MediaPullModeProducerGetBufferParams extends bindings.Struct { | 441 class _MediaPullModeProducerGetBufferParams extends bindings.Struct { |
420 static const List<bindings.StructDataHeader> kVersions = const [ | 442 static const List<bindings.StructDataHeader> kVersions = const [ |
421 const bindings.StructDataHeader(8, 0) | 443 const bindings.StructDataHeader(8, 0) |
422 ]; | 444 ]; |
423 | 445 |
424 _MediaPullModeProducerGetBufferParams() : super(kVersions.last.size); | 446 _MediaPullModeProducerGetBufferParams() : super(kVersions.last.size); |
425 | 447 |
| 448 _MediaPullModeProducerGetBufferParams.init( |
| 449 ) : super(kVersions.last.size); |
| 450 |
426 static _MediaPullModeProducerGetBufferParams deserialize(bindings.Message mess
age) { | 451 static _MediaPullModeProducerGetBufferParams deserialize(bindings.Message mess
age) { |
427 var decoder = new bindings.Decoder(message); | 452 var decoder = new bindings.Decoder(message); |
428 var result = decode(decoder); | 453 var result = decode(decoder); |
429 if (decoder.excessHandles != null) { | 454 if (decoder.excessHandles != null) { |
430 decoder.excessHandles.forEach((h) => h.close()); | 455 decoder.excessHandles.forEach((h) => h.close()); |
431 } | 456 } |
432 return result; | 457 return result; |
433 } | 458 } |
434 | 459 |
435 static _MediaPullModeProducerGetBufferParams decode(bindings.Decoder decoder0)
{ | 460 static _MediaPullModeProducerGetBufferParams decode(bindings.Decoder decoder0)
{ |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
475 | 500 |
476 | 501 |
477 class MediaPullModeProducerGetBufferResponseParams extends bindings.Struct { | 502 class MediaPullModeProducerGetBufferResponseParams extends bindings.Struct { |
478 static const List<bindings.StructDataHeader> kVersions = const [ | 503 static const List<bindings.StructDataHeader> kVersions = const [ |
479 const bindings.StructDataHeader(16, 0) | 504 const bindings.StructDataHeader(16, 0) |
480 ]; | 505 ]; |
481 core.MojoSharedBuffer buffer = null; | 506 core.MojoSharedBuffer buffer = null; |
482 | 507 |
483 MediaPullModeProducerGetBufferResponseParams() : super(kVersions.last.size); | 508 MediaPullModeProducerGetBufferResponseParams() : super(kVersions.last.size); |
484 | 509 |
| 510 MediaPullModeProducerGetBufferResponseParams.init( |
| 511 core.MojoSharedBuffer this.buffer |
| 512 ) : super(kVersions.last.size); |
| 513 |
485 static MediaPullModeProducerGetBufferResponseParams deserialize(bindings.Messa
ge message) { | 514 static MediaPullModeProducerGetBufferResponseParams deserialize(bindings.Messa
ge message) { |
486 var decoder = new bindings.Decoder(message); | 515 var decoder = new bindings.Decoder(message); |
487 var result = decode(decoder); | 516 var result = decode(decoder); |
488 if (decoder.excessHandles != null) { | 517 if (decoder.excessHandles != null) { |
489 decoder.excessHandles.forEach((h) => h.close()); | 518 decoder.excessHandles.forEach((h) => h.close()); |
490 } | 519 } |
491 return result; | 520 return result; |
492 } | 521 } |
493 | 522 |
494 static MediaPullModeProducerGetBufferResponseParams decode(bindings.Decoder de
coder0) { | 523 static MediaPullModeProducerGetBufferResponseParams decode(bindings.Decoder de
coder0) { |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
546 | 575 |
547 | 576 |
548 class _MediaPullModeProducerPullPacketParams extends bindings.Struct { | 577 class _MediaPullModeProducerPullPacketParams extends bindings.Struct { |
549 static const List<bindings.StructDataHeader> kVersions = const [ | 578 static const List<bindings.StructDataHeader> kVersions = const [ |
550 const bindings.StructDataHeader(16, 0) | 579 const bindings.StructDataHeader(16, 0) |
551 ]; | 580 ]; |
552 MediaPacket toRelease = null; | 581 MediaPacket toRelease = null; |
553 | 582 |
554 _MediaPullModeProducerPullPacketParams() : super(kVersions.last.size); | 583 _MediaPullModeProducerPullPacketParams() : super(kVersions.last.size); |
555 | 584 |
| 585 _MediaPullModeProducerPullPacketParams.init( |
| 586 MediaPacket this.toRelease |
| 587 ) : super(kVersions.last.size); |
| 588 |
556 static _MediaPullModeProducerPullPacketParams deserialize(bindings.Message mes
sage) { | 589 static _MediaPullModeProducerPullPacketParams deserialize(bindings.Message mes
sage) { |
557 var decoder = new bindings.Decoder(message); | 590 var decoder = new bindings.Decoder(message); |
558 var result = decode(decoder); | 591 var result = decode(decoder); |
559 if (decoder.excessHandles != null) { | 592 if (decoder.excessHandles != null) { |
560 decoder.excessHandles.forEach((h) => h.close()); | 593 decoder.excessHandles.forEach((h) => h.close()); |
561 } | 594 } |
562 return result; | 595 return result; |
563 } | 596 } |
564 | 597 |
565 static _MediaPullModeProducerPullPacketParams decode(bindings.Decoder decoder0
) { | 598 static _MediaPullModeProducerPullPacketParams decode(bindings.Decoder decoder0
) { |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
619 | 652 |
620 | 653 |
621 class MediaPullModeProducerPullPacketResponseParams extends bindings.Struct { | 654 class MediaPullModeProducerPullPacketResponseParams extends bindings.Struct { |
622 static const List<bindings.StructDataHeader> kVersions = const [ | 655 static const List<bindings.StructDataHeader> kVersions = const [ |
623 const bindings.StructDataHeader(16, 0) | 656 const bindings.StructDataHeader(16, 0) |
624 ]; | 657 ]; |
625 MediaPacket packet = null; | 658 MediaPacket packet = null; |
626 | 659 |
627 MediaPullModeProducerPullPacketResponseParams() : super(kVersions.last.size); | 660 MediaPullModeProducerPullPacketResponseParams() : super(kVersions.last.size); |
628 | 661 |
| 662 MediaPullModeProducerPullPacketResponseParams.init( |
| 663 MediaPacket this.packet |
| 664 ) : super(kVersions.last.size); |
| 665 |
629 static MediaPullModeProducerPullPacketResponseParams deserialize(bindings.Mess
age message) { | 666 static MediaPullModeProducerPullPacketResponseParams deserialize(bindings.Mess
age message) { |
630 var decoder = new bindings.Decoder(message); | 667 var decoder = new bindings.Decoder(message); |
631 var result = decode(decoder); | 668 var result = decode(decoder); |
632 if (decoder.excessHandles != null) { | 669 if (decoder.excessHandles != null) { |
633 decoder.excessHandles.forEach((h) => h.close()); | 670 decoder.excessHandles.forEach((h) => h.close()); |
634 } | 671 } |
635 return result; | 672 return result; |
636 } | 673 } |
637 | 674 |
638 static MediaPullModeProducerPullPacketResponseParams decode(bindings.Decoder d
ecoder0) { | 675 static MediaPullModeProducerPullPacketResponseParams decode(bindings.Decoder d
ecoder0) { |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
692 | 729 |
693 | 730 |
694 class _MediaPullModeProducerReleasePacketParams extends bindings.Struct { | 731 class _MediaPullModeProducerReleasePacketParams extends bindings.Struct { |
695 static const List<bindings.StructDataHeader> kVersions = const [ | 732 static const List<bindings.StructDataHeader> kVersions = const [ |
696 const bindings.StructDataHeader(16, 0) | 733 const bindings.StructDataHeader(16, 0) |
697 ]; | 734 ]; |
698 MediaPacket toRelease = null; | 735 MediaPacket toRelease = null; |
699 | 736 |
700 _MediaPullModeProducerReleasePacketParams() : super(kVersions.last.size); | 737 _MediaPullModeProducerReleasePacketParams() : super(kVersions.last.size); |
701 | 738 |
| 739 _MediaPullModeProducerReleasePacketParams.init( |
| 740 MediaPacket this.toRelease |
| 741 ) : super(kVersions.last.size); |
| 742 |
702 static _MediaPullModeProducerReleasePacketParams deserialize(bindings.Message
message) { | 743 static _MediaPullModeProducerReleasePacketParams deserialize(bindings.Message
message) { |
703 var decoder = new bindings.Decoder(message); | 744 var decoder = new bindings.Decoder(message); |
704 var result = decode(decoder); | 745 var result = decode(decoder); |
705 if (decoder.excessHandles != null) { | 746 if (decoder.excessHandles != null) { |
706 decoder.excessHandles.forEach((h) => h.close()); | 747 decoder.excessHandles.forEach((h) => h.close()); |
707 } | 748 } |
708 return result; | 749 return result; |
709 } | 750 } |
710 | 751 |
711 static _MediaPullModeProducerReleasePacketParams decode(bindings.Decoder decod
er0) { | 752 static _MediaPullModeProducerReleasePacketParams decode(bindings.Decoder decod
er0) { |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
765 | 806 |
766 | 807 |
767 class _MediaConsumerSetBufferParams extends bindings.Struct { | 808 class _MediaConsumerSetBufferParams extends bindings.Struct { |
768 static const List<bindings.StructDataHeader> kVersions = const [ | 809 static const List<bindings.StructDataHeader> kVersions = const [ |
769 const bindings.StructDataHeader(16, 0) | 810 const bindings.StructDataHeader(16, 0) |
770 ]; | 811 ]; |
771 core.MojoSharedBuffer buffer = null; | 812 core.MojoSharedBuffer buffer = null; |
772 | 813 |
773 _MediaConsumerSetBufferParams() : super(kVersions.last.size); | 814 _MediaConsumerSetBufferParams() : super(kVersions.last.size); |
774 | 815 |
| 816 _MediaConsumerSetBufferParams.init( |
| 817 core.MojoSharedBuffer this.buffer |
| 818 ) : super(kVersions.last.size); |
| 819 |
775 static _MediaConsumerSetBufferParams deserialize(bindings.Message message) { | 820 static _MediaConsumerSetBufferParams deserialize(bindings.Message message) { |
776 var decoder = new bindings.Decoder(message); | 821 var decoder = new bindings.Decoder(message); |
777 var result = decode(decoder); | 822 var result = decode(decoder); |
778 if (decoder.excessHandles != null) { | 823 if (decoder.excessHandles != null) { |
779 decoder.excessHandles.forEach((h) => h.close()); | 824 decoder.excessHandles.forEach((h) => h.close()); |
780 } | 825 } |
781 return result; | 826 return result; |
782 } | 827 } |
783 | 828 |
784 static _MediaConsumerSetBufferParams decode(bindings.Decoder decoder0) { | 829 static _MediaConsumerSetBufferParams decode(bindings.Decoder decoder0) { |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
835 } | 880 } |
836 | 881 |
837 | 882 |
838 class MediaConsumerSetBufferResponseParams extends bindings.Struct { | 883 class MediaConsumerSetBufferResponseParams extends bindings.Struct { |
839 static const List<bindings.StructDataHeader> kVersions = const [ | 884 static const List<bindings.StructDataHeader> kVersions = const [ |
840 const bindings.StructDataHeader(8, 0) | 885 const bindings.StructDataHeader(8, 0) |
841 ]; | 886 ]; |
842 | 887 |
843 MediaConsumerSetBufferResponseParams() : super(kVersions.last.size); | 888 MediaConsumerSetBufferResponseParams() : super(kVersions.last.size); |
844 | 889 |
| 890 MediaConsumerSetBufferResponseParams.init( |
| 891 ) : super(kVersions.last.size); |
| 892 |
845 static MediaConsumerSetBufferResponseParams deserialize(bindings.Message messa
ge) { | 893 static MediaConsumerSetBufferResponseParams deserialize(bindings.Message messa
ge) { |
846 var decoder = new bindings.Decoder(message); | 894 var decoder = new bindings.Decoder(message); |
847 var result = decode(decoder); | 895 var result = decode(decoder); |
848 if (decoder.excessHandles != null) { | 896 if (decoder.excessHandles != null) { |
849 decoder.excessHandles.forEach((h) => h.close()); | 897 decoder.excessHandles.forEach((h) => h.close()); |
850 } | 898 } |
851 return result; | 899 return result; |
852 } | 900 } |
853 | 901 |
854 static MediaConsumerSetBufferResponseParams decode(bindings.Decoder decoder0)
{ | 902 static MediaConsumerSetBufferResponseParams decode(bindings.Decoder decoder0)
{ |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
894 | 942 |
895 | 943 |
896 class _MediaConsumerSendPacketParams extends bindings.Struct { | 944 class _MediaConsumerSendPacketParams extends bindings.Struct { |
897 static const List<bindings.StructDataHeader> kVersions = const [ | 945 static const List<bindings.StructDataHeader> kVersions = const [ |
898 const bindings.StructDataHeader(16, 0) | 946 const bindings.StructDataHeader(16, 0) |
899 ]; | 947 ]; |
900 MediaPacket packet = null; | 948 MediaPacket packet = null; |
901 | 949 |
902 _MediaConsumerSendPacketParams() : super(kVersions.last.size); | 950 _MediaConsumerSendPacketParams() : super(kVersions.last.size); |
903 | 951 |
| 952 _MediaConsumerSendPacketParams.init( |
| 953 MediaPacket this.packet |
| 954 ) : super(kVersions.last.size); |
| 955 |
904 static _MediaConsumerSendPacketParams deserialize(bindings.Message message) { | 956 static _MediaConsumerSendPacketParams deserialize(bindings.Message message) { |
905 var decoder = new bindings.Decoder(message); | 957 var decoder = new bindings.Decoder(message); |
906 var result = decode(decoder); | 958 var result = decode(decoder); |
907 if (decoder.excessHandles != null) { | 959 if (decoder.excessHandles != null) { |
908 decoder.excessHandles.forEach((h) => h.close()); | 960 decoder.excessHandles.forEach((h) => h.close()); |
909 } | 961 } |
910 return result; | 962 return result; |
911 } | 963 } |
912 | 964 |
913 static _MediaConsumerSendPacketParams decode(bindings.Decoder decoder0) { | 965 static _MediaConsumerSendPacketParams decode(bindings.Decoder decoder0) { |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
967 | 1019 |
968 | 1020 |
969 class MediaConsumerSendPacketResponseParams extends bindings.Struct { | 1021 class MediaConsumerSendPacketResponseParams extends bindings.Struct { |
970 static const List<bindings.StructDataHeader> kVersions = const [ | 1022 static const List<bindings.StructDataHeader> kVersions = const [ |
971 const bindings.StructDataHeader(16, 0) | 1023 const bindings.StructDataHeader(16, 0) |
972 ]; | 1024 ]; |
973 MediaConsumerSendResult result = null; | 1025 MediaConsumerSendResult result = null; |
974 | 1026 |
975 MediaConsumerSendPacketResponseParams() : super(kVersions.last.size); | 1027 MediaConsumerSendPacketResponseParams() : super(kVersions.last.size); |
976 | 1028 |
| 1029 MediaConsumerSendPacketResponseParams.init( |
| 1030 MediaConsumerSendResult this.result |
| 1031 ) : super(kVersions.last.size); |
| 1032 |
977 static MediaConsumerSendPacketResponseParams deserialize(bindings.Message mess
age) { | 1033 static MediaConsumerSendPacketResponseParams deserialize(bindings.Message mess
age) { |
978 var decoder = new bindings.Decoder(message); | 1034 var decoder = new bindings.Decoder(message); |
979 var result = decode(decoder); | 1035 var result = decode(decoder); |
980 if (decoder.excessHandles != null) { | 1036 if (decoder.excessHandles != null) { |
981 decoder.excessHandles.forEach((h) => h.close()); | 1037 decoder.excessHandles.forEach((h) => h.close()); |
982 } | 1038 } |
983 return result; | 1039 return result; |
984 } | 1040 } |
985 | 1041 |
986 static MediaConsumerSendPacketResponseParams decode(bindings.Decoder decoder0)
{ | 1042 static MediaConsumerSendPacketResponseParams decode(bindings.Decoder decoder0)
{ |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1042 } | 1098 } |
1043 | 1099 |
1044 | 1100 |
1045 class _MediaConsumerPrimeParams extends bindings.Struct { | 1101 class _MediaConsumerPrimeParams extends bindings.Struct { |
1046 static const List<bindings.StructDataHeader> kVersions = const [ | 1102 static const List<bindings.StructDataHeader> kVersions = const [ |
1047 const bindings.StructDataHeader(8, 0) | 1103 const bindings.StructDataHeader(8, 0) |
1048 ]; | 1104 ]; |
1049 | 1105 |
1050 _MediaConsumerPrimeParams() : super(kVersions.last.size); | 1106 _MediaConsumerPrimeParams() : super(kVersions.last.size); |
1051 | 1107 |
| 1108 _MediaConsumerPrimeParams.init( |
| 1109 ) : super(kVersions.last.size); |
| 1110 |
1052 static _MediaConsumerPrimeParams deserialize(bindings.Message message) { | 1111 static _MediaConsumerPrimeParams deserialize(bindings.Message message) { |
1053 var decoder = new bindings.Decoder(message); | 1112 var decoder = new bindings.Decoder(message); |
1054 var result = decode(decoder); | 1113 var result = decode(decoder); |
1055 if (decoder.excessHandles != null) { | 1114 if (decoder.excessHandles != null) { |
1056 decoder.excessHandles.forEach((h) => h.close()); | 1115 decoder.excessHandles.forEach((h) => h.close()); |
1057 } | 1116 } |
1058 return result; | 1117 return result; |
1059 } | 1118 } |
1060 | 1119 |
1061 static _MediaConsumerPrimeParams decode(bindings.Decoder decoder0) { | 1120 static _MediaConsumerPrimeParams decode(bindings.Decoder decoder0) { |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1100 } | 1159 } |
1101 | 1160 |
1102 | 1161 |
1103 class MediaConsumerPrimeResponseParams extends bindings.Struct { | 1162 class MediaConsumerPrimeResponseParams extends bindings.Struct { |
1104 static const List<bindings.StructDataHeader> kVersions = const [ | 1163 static const List<bindings.StructDataHeader> kVersions = const [ |
1105 const bindings.StructDataHeader(8, 0) | 1164 const bindings.StructDataHeader(8, 0) |
1106 ]; | 1165 ]; |
1107 | 1166 |
1108 MediaConsumerPrimeResponseParams() : super(kVersions.last.size); | 1167 MediaConsumerPrimeResponseParams() : super(kVersions.last.size); |
1109 | 1168 |
| 1169 MediaConsumerPrimeResponseParams.init( |
| 1170 ) : super(kVersions.last.size); |
| 1171 |
1110 static MediaConsumerPrimeResponseParams deserialize(bindings.Message message)
{ | 1172 static MediaConsumerPrimeResponseParams deserialize(bindings.Message message)
{ |
1111 var decoder = new bindings.Decoder(message); | 1173 var decoder = new bindings.Decoder(message); |
1112 var result = decode(decoder); | 1174 var result = decode(decoder); |
1113 if (decoder.excessHandles != null) { | 1175 if (decoder.excessHandles != null) { |
1114 decoder.excessHandles.forEach((h) => h.close()); | 1176 decoder.excessHandles.forEach((h) => h.close()); |
1115 } | 1177 } |
1116 return result; | 1178 return result; |
1117 } | 1179 } |
1118 | 1180 |
1119 static MediaConsumerPrimeResponseParams decode(bindings.Decoder decoder0) { | 1181 static MediaConsumerPrimeResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1158 } | 1220 } |
1159 | 1221 |
1160 | 1222 |
1161 class _MediaConsumerFlushParams extends bindings.Struct { | 1223 class _MediaConsumerFlushParams extends bindings.Struct { |
1162 static const List<bindings.StructDataHeader> kVersions = const [ | 1224 static const List<bindings.StructDataHeader> kVersions = const [ |
1163 const bindings.StructDataHeader(8, 0) | 1225 const bindings.StructDataHeader(8, 0) |
1164 ]; | 1226 ]; |
1165 | 1227 |
1166 _MediaConsumerFlushParams() : super(kVersions.last.size); | 1228 _MediaConsumerFlushParams() : super(kVersions.last.size); |
1167 | 1229 |
| 1230 _MediaConsumerFlushParams.init( |
| 1231 ) : super(kVersions.last.size); |
| 1232 |
1168 static _MediaConsumerFlushParams deserialize(bindings.Message message) { | 1233 static _MediaConsumerFlushParams deserialize(bindings.Message message) { |
1169 var decoder = new bindings.Decoder(message); | 1234 var decoder = new bindings.Decoder(message); |
1170 var result = decode(decoder); | 1235 var result = decode(decoder); |
1171 if (decoder.excessHandles != null) { | 1236 if (decoder.excessHandles != null) { |
1172 decoder.excessHandles.forEach((h) => h.close()); | 1237 decoder.excessHandles.forEach((h) => h.close()); |
1173 } | 1238 } |
1174 return result; | 1239 return result; |
1175 } | 1240 } |
1176 | 1241 |
1177 static _MediaConsumerFlushParams decode(bindings.Decoder decoder0) { | 1242 static _MediaConsumerFlushParams decode(bindings.Decoder decoder0) { |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1216 } | 1281 } |
1217 | 1282 |
1218 | 1283 |
1219 class MediaConsumerFlushResponseParams extends bindings.Struct { | 1284 class MediaConsumerFlushResponseParams extends bindings.Struct { |
1220 static const List<bindings.StructDataHeader> kVersions = const [ | 1285 static const List<bindings.StructDataHeader> kVersions = const [ |
1221 const bindings.StructDataHeader(8, 0) | 1286 const bindings.StructDataHeader(8, 0) |
1222 ]; | 1287 ]; |
1223 | 1288 |
1224 MediaConsumerFlushResponseParams() : super(kVersions.last.size); | 1289 MediaConsumerFlushResponseParams() : super(kVersions.last.size); |
1225 | 1290 |
| 1291 MediaConsumerFlushResponseParams.init( |
| 1292 ) : super(kVersions.last.size); |
| 1293 |
1226 static MediaConsumerFlushResponseParams deserialize(bindings.Message message)
{ | 1294 static MediaConsumerFlushResponseParams deserialize(bindings.Message message)
{ |
1227 var decoder = new bindings.Decoder(message); | 1295 var decoder = new bindings.Decoder(message); |
1228 var result = decode(decoder); | 1296 var result = decode(decoder); |
1229 if (decoder.excessHandles != null) { | 1297 if (decoder.excessHandles != null) { |
1230 decoder.excessHandles.forEach((h) => h.close()); | 1298 decoder.excessHandles.forEach((h) => h.close()); |
1231 } | 1299 } |
1232 return result; | 1300 return result; |
1233 } | 1301 } |
1234 | 1302 |
1235 static MediaConsumerFlushResponseParams decode(bindings.Decoder decoder0) { | 1303 static MediaConsumerFlushResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1270 Map toJson() { | 1338 Map toJson() { |
1271 Map map = new Map(); | 1339 Map map = new Map(); |
1272 return map; | 1340 return map; |
1273 } | 1341 } |
1274 } | 1342 } |
1275 | 1343 |
1276 const int _mediaProducerMethodConnectName = 0; | 1344 const int _mediaProducerMethodConnectName = 0; |
1277 const int _mediaProducerMethodDisconnectName = 1; | 1345 const int _mediaProducerMethodDisconnectName = 1; |
1278 | 1346 |
1279 class _MediaProducerServiceDescription implements service_describer.ServiceDescr
iption { | 1347 class _MediaProducerServiceDescription implements service_describer.ServiceDescr
iption { |
1280 dynamic getTopLevelInterface([Function responseFactory]) => | 1348 void getTopLevelInterface(Function responder) { |
1281 responseFactory(null); | 1349 responder(null); |
| 1350 } |
1282 | 1351 |
1283 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 1352 void getTypeDefinition(String typeKey, Function responder) { |
1284 responseFactory(null); | 1353 responder(null); |
| 1354 } |
1285 | 1355 |
1286 dynamic getAllTypeDefinitions([Function responseFactory]) => | 1356 void getAllTypeDefinitions(Function responder) { |
1287 responseFactory(null); | 1357 responder(null); |
| 1358 } |
1288 } | 1359 } |
1289 | 1360 |
1290 abstract class MediaProducer { | 1361 abstract class MediaProducer { |
1291 static const String serviceName = null; | 1362 static const String serviceName = null; |
1292 | 1363 |
1293 static service_describer.ServiceDescription _cachedServiceDescription; | 1364 static service_describer.ServiceDescription _cachedServiceDescription; |
1294 static service_describer.ServiceDescription get serviceDescription { | 1365 static service_describer.ServiceDescription get serviceDescription { |
1295 if (_cachedServiceDescription == null) { | 1366 if (_cachedServiceDescription == null) { |
1296 _cachedServiceDescription = new _MediaProducerServiceDescription(); | 1367 _cachedServiceDescription = new _MediaProducerServiceDescription(); |
1297 } | 1368 } |
1298 return _cachedServiceDescription; | 1369 return _cachedServiceDescription; |
1299 } | 1370 } |
1300 | 1371 |
1301 static MediaProducerProxy connectToService( | 1372 static MediaProducerProxy connectToService( |
1302 bindings.ServiceConnector s, String url, [String serviceName]) { | 1373 bindings.ServiceConnector s, String url, [String serviceName]) { |
1303 MediaProducerProxy p = new MediaProducerProxy.unbound(); | 1374 MediaProducerProxy p = new MediaProducerProxy.unbound(); |
1304 String name = serviceName ?? MediaProducer.serviceName; | 1375 String name = serviceName ?? MediaProducer.serviceName; |
1305 if ((name == null) || name.isEmpty) { | 1376 if ((name == null) || name.isEmpty) { |
1306 throw new core.MojoApiError( | 1377 throw new core.MojoApiError( |
1307 "If an interface has no ServiceName, then one must be provided."); | 1378 "If an interface has no ServiceName, then one must be provided."); |
1308 } | 1379 } |
1309 s.connectToService(url, p, name); | 1380 s.connectToService(url, p, name); |
1310 return p; | 1381 return p; |
1311 } | 1382 } |
1312 dynamic connect(MediaConsumerInterface consumer,[Function responseFactory = nu
ll]); | 1383 void connect(MediaConsumerInterface consumer,void callback()); |
1313 void disconnect(); | 1384 void disconnect(); |
1314 } | 1385 } |
1315 | 1386 |
1316 abstract class MediaProducerInterface | 1387 abstract class MediaProducerInterface |
1317 implements bindings.MojoInterface<MediaProducer>, | 1388 implements bindings.MojoInterface<MediaProducer>, |
1318 MediaProducer { | 1389 MediaProducer { |
1319 factory MediaProducerInterface([MediaProducer impl]) => | 1390 factory MediaProducerInterface([MediaProducer impl]) => |
1320 new MediaProducerStub.unbound(impl); | 1391 new MediaProducerStub.unbound(impl); |
1321 | 1392 |
1322 factory MediaProducerInterface.fromEndpoint( | 1393 factory MediaProducerInterface.fromEndpoint( |
(...skipping 30 matching lines...) Expand all Loading... |
1353 | 1424 |
1354 void handleResponse(bindings.ServiceMessage message) { | 1425 void handleResponse(bindings.ServiceMessage message) { |
1355 switch (message.header.type) { | 1426 switch (message.header.type) { |
1356 case _mediaProducerMethodConnectName: | 1427 case _mediaProducerMethodConnectName: |
1357 var r = MediaProducerConnectResponseParams.deserialize( | 1428 var r = MediaProducerConnectResponseParams.deserialize( |
1358 message.payload); | 1429 message.payload); |
1359 if (!message.header.hasRequestId) { | 1430 if (!message.header.hasRequestId) { |
1360 proxyError("Expected a message with a valid request Id."); | 1431 proxyError("Expected a message with a valid request Id."); |
1361 return; | 1432 return; |
1362 } | 1433 } |
1363 Completer c = completerMap[message.header.requestId]; | 1434 Function callback = callbackMap[message.header.requestId]; |
1364 if (c == null) { | 1435 if (callback == null) { |
1365 proxyError( | 1436 proxyError( |
1366 "Message had unknown request Id: ${message.header.requestId}"); | 1437 "Message had unknown request Id: ${message.header.requestId}"); |
1367 return; | 1438 return; |
1368 } | 1439 } |
1369 completerMap.remove(message.header.requestId); | 1440 callbackMap.remove(message.header.requestId); |
1370 if (c.isCompleted) { | 1441 callback(); |
1371 proxyError("Response completer already completed"); | |
1372 return; | |
1373 } | |
1374 c.complete(r); | |
1375 break; | 1442 break; |
1376 default: | 1443 default: |
1377 proxyError("Unexpected message type: ${message.header.type}"); | 1444 proxyError("Unexpected message type: ${message.header.type}"); |
1378 close(immediate: true); | 1445 close(immediate: true); |
1379 break; | 1446 break; |
1380 } | 1447 } |
1381 } | 1448 } |
1382 | 1449 |
1383 @override | 1450 @override |
1384 String toString() { | 1451 String toString() { |
(...skipping 24 matching lines...) Expand all Loading... |
1409 return newMockedProxy; | 1476 return newMockedProxy; |
1410 } | 1477 } |
1411 | 1478 |
1412 static MediaProducerProxy newFromEndpoint( | 1479 static MediaProducerProxy newFromEndpoint( |
1413 core.MojoMessagePipeEndpoint endpoint) { | 1480 core.MojoMessagePipeEndpoint endpoint) { |
1414 assert(endpoint.setDescription("For MediaProducerProxy")); | 1481 assert(endpoint.setDescription("For MediaProducerProxy")); |
1415 return new MediaProducerProxy.fromEndpoint(endpoint); | 1482 return new MediaProducerProxy.fromEndpoint(endpoint); |
1416 } | 1483 } |
1417 | 1484 |
1418 | 1485 |
1419 dynamic connect(MediaConsumerInterface consumer,[Function responseFactory = nu
ll]) { | 1486 void connect(MediaConsumerInterface consumer,void callback()) { |
1420 if (impl != null) { | 1487 if (impl != null) { |
1421 return new Future(() => impl.connect(consumer,_MediaProducerStubControl._m
ediaProducerConnectResponseParamsFactory)); | 1488 impl.connect(consumer,callback); |
| 1489 return; |
1422 } | 1490 } |
1423 var params = new _MediaProducerConnectParams(); | 1491 var params = new _MediaProducerConnectParams(); |
1424 params.consumer = consumer; | 1492 params.consumer = consumer; |
1425 return ctrl.sendMessageWithRequestId( | 1493 ctrl.sendMessageWithRequestId( |
1426 params, | 1494 params, |
1427 _mediaProducerMethodConnectName, | 1495 _mediaProducerMethodConnectName, |
1428 -1, | 1496 -1, |
1429 bindings.MessageHeader.kMessageExpectsResponse); | 1497 bindings.MessageHeader.kMessageExpectsResponse, |
| 1498 callback); |
1430 } | 1499 } |
1431 void disconnect() { | 1500 void disconnect() { |
1432 if (impl != null) { | 1501 if (impl != null) { |
1433 impl.disconnect(); | 1502 impl.disconnect(); |
1434 return; | 1503 return; |
1435 } | 1504 } |
1436 if (!ctrl.isBound) { | 1505 if (!ctrl.isBound) { |
1437 ctrl.proxyError("The Proxy is closed."); | 1506 ctrl.proxyError("The Proxy is closed."); |
1438 return; | 1507 return; |
1439 } | 1508 } |
(...skipping 18 matching lines...) Expand all Loading... |
1458 core.MojoHandle handle, [MediaProducer impl]) | 1527 core.MojoHandle handle, [MediaProducer impl]) |
1459 : super.fromHandle(handle, autoBegin: impl != null) { | 1528 : super.fromHandle(handle, autoBegin: impl != null) { |
1460 _impl = impl; | 1529 _impl = impl; |
1461 } | 1530 } |
1462 | 1531 |
1463 _MediaProducerStubControl.unbound([this._impl]) : super.unbound(); | 1532 _MediaProducerStubControl.unbound([this._impl]) : super.unbound(); |
1464 | 1533 |
1465 String get serviceName => MediaProducer.serviceName; | 1534 String get serviceName => MediaProducer.serviceName; |
1466 | 1535 |
1467 | 1536 |
1468 static MediaProducerConnectResponseParams _mediaProducerConnectResponseParamsF
actory() { | 1537 Function _mediaProducerConnectResponseParamsResponder( |
1469 var result = new MediaProducerConnectResponseParams(); | 1538 int requestId) { |
1470 return result; | 1539 return () { |
| 1540 var result = new MediaProducerConnectResponseParams(); |
| 1541 sendResponse(buildResponseWithId( |
| 1542 result, |
| 1543 _mediaProducerMethodConnectName, |
| 1544 requestId, |
| 1545 bindings.MessageHeader.kMessageIsResponse)); |
| 1546 }; |
1471 } | 1547 } |
1472 | 1548 |
1473 dynamic handleMessage(bindings.ServiceMessage message) { | 1549 void handleMessage(bindings.ServiceMessage message) { |
1474 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 1550 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
1475 return bindings.ControlMessageHandler.handleMessage(this, | 1551 bindings.ControlMessageHandler.handleMessage( |
1476 0, | 1552 this, 0, message); |
1477 message); | 1553 return; |
1478 } | 1554 } |
1479 if (_impl == null) { | 1555 if (_impl == null) { |
1480 throw new core.MojoApiError("$this has no implementation set"); | 1556 throw new core.MojoApiError("$this has no implementation set"); |
1481 } | 1557 } |
1482 switch (message.header.type) { | 1558 switch (message.header.type) { |
1483 case _mediaProducerMethodConnectName: | 1559 case _mediaProducerMethodConnectName: |
1484 var params = _MediaProducerConnectParams.deserialize( | 1560 var params = _MediaProducerConnectParams.deserialize( |
1485 message.payload); | 1561 message.payload); |
1486 var response = _impl.connect(params.consumer,_mediaProducerConnectRespon
seParamsFactory); | 1562 _impl.connect(params.consumer, _mediaProducerConnectResponseParamsRespon
der(message.header.requestId)); |
1487 if (response is Future) { | |
1488 return response.then((response) { | |
1489 if (response != null) { | |
1490 return buildResponseWithId( | |
1491 response, | |
1492 _mediaProducerMethodConnectName, | |
1493 message.header.requestId, | |
1494 bindings.MessageHeader.kMessageIsResponse); | |
1495 } | |
1496 }); | |
1497 } else if (response != null) { | |
1498 return buildResponseWithId( | |
1499 response, | |
1500 _mediaProducerMethodConnectName, | |
1501 message.header.requestId, | |
1502 bindings.MessageHeader.kMessageIsResponse); | |
1503 } | |
1504 break; | 1563 break; |
1505 case _mediaProducerMethodDisconnectName: | 1564 case _mediaProducerMethodDisconnectName: |
1506 _impl.disconnect(); | 1565 _impl.disconnect(); |
1507 break; | 1566 break; |
1508 default: | 1567 default: |
1509 throw new bindings.MojoCodecError("Unexpected message name"); | 1568 throw new bindings.MojoCodecError("Unexpected message name"); |
1510 break; | 1569 break; |
1511 } | 1570 } |
1512 return null; | |
1513 } | 1571 } |
1514 | 1572 |
1515 MediaProducer get impl => _impl; | 1573 MediaProducer get impl => _impl; |
1516 set impl(MediaProducer d) { | 1574 set impl(MediaProducer d) { |
1517 if (d == null) { | 1575 if (d == null) { |
1518 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 1576 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
1519 } | 1577 } |
1520 if (isBound && (_impl == null)) { | 1578 if (isBound && (_impl == null)) { |
1521 beginHandlingEvents(); | 1579 beginHandlingEvents(); |
1522 } | 1580 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1556 core.MojoHandle handle, [MediaProducer impl]) | 1614 core.MojoHandle handle, [MediaProducer impl]) |
1557 : super(new _MediaProducerStubControl.fromHandle(handle, impl)); | 1615 : super(new _MediaProducerStubControl.fromHandle(handle, impl)); |
1558 | 1616 |
1559 static MediaProducerStub newFromEndpoint( | 1617 static MediaProducerStub newFromEndpoint( |
1560 core.MojoMessagePipeEndpoint endpoint) { | 1618 core.MojoMessagePipeEndpoint endpoint) { |
1561 assert(endpoint.setDescription("For MediaProducerStub")); | 1619 assert(endpoint.setDescription("For MediaProducerStub")); |
1562 return new MediaProducerStub.fromEndpoint(endpoint); | 1620 return new MediaProducerStub.fromEndpoint(endpoint); |
1563 } | 1621 } |
1564 | 1622 |
1565 | 1623 |
1566 dynamic connect(MediaConsumerInterface consumer,[Function responseFactory = nu
ll]) { | 1624 void connect(MediaConsumerInterface consumer,void callback()) { |
1567 return impl.connect(consumer,responseFactory); | 1625 return impl.connect(consumer,callback); |
1568 } | 1626 } |
1569 void disconnect() { | 1627 void disconnect() { |
1570 return impl.disconnect(); | 1628 return impl.disconnect(); |
1571 } | 1629 } |
1572 } | 1630 } |
1573 | 1631 |
1574 const int _mediaPullModeProducerMethodGetBufferName = 0; | 1632 const int _mediaPullModeProducerMethodGetBufferName = 0; |
1575 const int _mediaPullModeProducerMethodPullPacketName = 1; | 1633 const int _mediaPullModeProducerMethodPullPacketName = 1; |
1576 const int _mediaPullModeProducerMethodReleasePacketName = 2; | 1634 const int _mediaPullModeProducerMethodReleasePacketName = 2; |
1577 | 1635 |
1578 class _MediaPullModeProducerServiceDescription implements service_describer.Serv
iceDescription { | 1636 class _MediaPullModeProducerServiceDescription implements service_describer.Serv
iceDescription { |
1579 dynamic getTopLevelInterface([Function responseFactory]) => | 1637 void getTopLevelInterface(Function responder) { |
1580 responseFactory(null); | 1638 responder(null); |
| 1639 } |
1581 | 1640 |
1582 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 1641 void getTypeDefinition(String typeKey, Function responder) { |
1583 responseFactory(null); | 1642 responder(null); |
| 1643 } |
1584 | 1644 |
1585 dynamic getAllTypeDefinitions([Function responseFactory]) => | 1645 void getAllTypeDefinitions(Function responder) { |
1586 responseFactory(null); | 1646 responder(null); |
| 1647 } |
1587 } | 1648 } |
1588 | 1649 |
1589 abstract class MediaPullModeProducer { | 1650 abstract class MediaPullModeProducer { |
1590 static const String serviceName = null; | 1651 static const String serviceName = null; |
1591 | 1652 |
1592 static service_describer.ServiceDescription _cachedServiceDescription; | 1653 static service_describer.ServiceDescription _cachedServiceDescription; |
1593 static service_describer.ServiceDescription get serviceDescription { | 1654 static service_describer.ServiceDescription get serviceDescription { |
1594 if (_cachedServiceDescription == null) { | 1655 if (_cachedServiceDescription == null) { |
1595 _cachedServiceDescription = new _MediaPullModeProducerServiceDescription()
; | 1656 _cachedServiceDescription = new _MediaPullModeProducerServiceDescription()
; |
1596 } | 1657 } |
1597 return _cachedServiceDescription; | 1658 return _cachedServiceDescription; |
1598 } | 1659 } |
1599 | 1660 |
1600 static MediaPullModeProducerProxy connectToService( | 1661 static MediaPullModeProducerProxy connectToService( |
1601 bindings.ServiceConnector s, String url, [String serviceName]) { | 1662 bindings.ServiceConnector s, String url, [String serviceName]) { |
1602 MediaPullModeProducerProxy p = new MediaPullModeProducerProxy.unbound(); | 1663 MediaPullModeProducerProxy p = new MediaPullModeProducerProxy.unbound(); |
1603 String name = serviceName ?? MediaPullModeProducer.serviceName; | 1664 String name = serviceName ?? MediaPullModeProducer.serviceName; |
1604 if ((name == null) || name.isEmpty) { | 1665 if ((name == null) || name.isEmpty) { |
1605 throw new core.MojoApiError( | 1666 throw new core.MojoApiError( |
1606 "If an interface has no ServiceName, then one must be provided."); | 1667 "If an interface has no ServiceName, then one must be provided."); |
1607 } | 1668 } |
1608 s.connectToService(url, p, name); | 1669 s.connectToService(url, p, name); |
1609 return p; | 1670 return p; |
1610 } | 1671 } |
1611 dynamic getBuffer([Function responseFactory = null]); | 1672 void getBuffer(void callback(core.MojoSharedBuffer buffer)); |
1612 dynamic pullPacket(MediaPacket toRelease,[Function responseFactory = null]); | 1673 void pullPacket(MediaPacket toRelease,void callback(MediaPacket packet)); |
1613 void releasePacket(MediaPacket toRelease); | 1674 void releasePacket(MediaPacket toRelease); |
1614 } | 1675 } |
1615 | 1676 |
1616 abstract class MediaPullModeProducerInterface | 1677 abstract class MediaPullModeProducerInterface |
1617 implements bindings.MojoInterface<MediaPullModeProducer>, | 1678 implements bindings.MojoInterface<MediaPullModeProducer>, |
1618 MediaPullModeProducer { | 1679 MediaPullModeProducer { |
1619 factory MediaPullModeProducerInterface([MediaPullModeProducer impl]) => | 1680 factory MediaPullModeProducerInterface([MediaPullModeProducer impl]) => |
1620 new MediaPullModeProducerStub.unbound(impl); | 1681 new MediaPullModeProducerStub.unbound(impl); |
1621 | 1682 |
1622 factory MediaPullModeProducerInterface.fromEndpoint( | 1683 factory MediaPullModeProducerInterface.fromEndpoint( |
(...skipping 30 matching lines...) Expand all Loading... |
1653 | 1714 |
1654 void handleResponse(bindings.ServiceMessage message) { | 1715 void handleResponse(bindings.ServiceMessage message) { |
1655 switch (message.header.type) { | 1716 switch (message.header.type) { |
1656 case _mediaPullModeProducerMethodGetBufferName: | 1717 case _mediaPullModeProducerMethodGetBufferName: |
1657 var r = MediaPullModeProducerGetBufferResponseParams.deserialize( | 1718 var r = MediaPullModeProducerGetBufferResponseParams.deserialize( |
1658 message.payload); | 1719 message.payload); |
1659 if (!message.header.hasRequestId) { | 1720 if (!message.header.hasRequestId) { |
1660 proxyError("Expected a message with a valid request Id."); | 1721 proxyError("Expected a message with a valid request Id."); |
1661 return; | 1722 return; |
1662 } | 1723 } |
1663 Completer c = completerMap[message.header.requestId]; | 1724 Function callback = callbackMap[message.header.requestId]; |
1664 if (c == null) { | 1725 if (callback == null) { |
1665 proxyError( | 1726 proxyError( |
1666 "Message had unknown request Id: ${message.header.requestId}"); | 1727 "Message had unknown request Id: ${message.header.requestId}"); |
1667 return; | 1728 return; |
1668 } | 1729 } |
1669 completerMap.remove(message.header.requestId); | 1730 callbackMap.remove(message.header.requestId); |
1670 if (c.isCompleted) { | 1731 callback(r.buffer ); |
1671 proxyError("Response completer already completed"); | |
1672 return; | |
1673 } | |
1674 c.complete(r); | |
1675 break; | 1732 break; |
1676 case _mediaPullModeProducerMethodPullPacketName: | 1733 case _mediaPullModeProducerMethodPullPacketName: |
1677 var r = MediaPullModeProducerPullPacketResponseParams.deserialize( | 1734 var r = MediaPullModeProducerPullPacketResponseParams.deserialize( |
1678 message.payload); | 1735 message.payload); |
1679 if (!message.header.hasRequestId) { | 1736 if (!message.header.hasRequestId) { |
1680 proxyError("Expected a message with a valid request Id."); | 1737 proxyError("Expected a message with a valid request Id."); |
1681 return; | 1738 return; |
1682 } | 1739 } |
1683 Completer c = completerMap[message.header.requestId]; | 1740 Function callback = callbackMap[message.header.requestId]; |
1684 if (c == null) { | 1741 if (callback == null) { |
1685 proxyError( | 1742 proxyError( |
1686 "Message had unknown request Id: ${message.header.requestId}"); | 1743 "Message had unknown request Id: ${message.header.requestId}"); |
1687 return; | 1744 return; |
1688 } | 1745 } |
1689 completerMap.remove(message.header.requestId); | 1746 callbackMap.remove(message.header.requestId); |
1690 if (c.isCompleted) { | 1747 callback(r.packet ); |
1691 proxyError("Response completer already completed"); | |
1692 return; | |
1693 } | |
1694 c.complete(r); | |
1695 break; | 1748 break; |
1696 default: | 1749 default: |
1697 proxyError("Unexpected message type: ${message.header.type}"); | 1750 proxyError("Unexpected message type: ${message.header.type}"); |
1698 close(immediate: true); | 1751 close(immediate: true); |
1699 break; | 1752 break; |
1700 } | 1753 } |
1701 } | 1754 } |
1702 | 1755 |
1703 @override | 1756 @override |
1704 String toString() { | 1757 String toString() { |
(...skipping 24 matching lines...) Expand all Loading... |
1729 return newMockedProxy; | 1782 return newMockedProxy; |
1730 } | 1783 } |
1731 | 1784 |
1732 static MediaPullModeProducerProxy newFromEndpoint( | 1785 static MediaPullModeProducerProxy newFromEndpoint( |
1733 core.MojoMessagePipeEndpoint endpoint) { | 1786 core.MojoMessagePipeEndpoint endpoint) { |
1734 assert(endpoint.setDescription("For MediaPullModeProducerProxy")); | 1787 assert(endpoint.setDescription("For MediaPullModeProducerProxy")); |
1735 return new MediaPullModeProducerProxy.fromEndpoint(endpoint); | 1788 return new MediaPullModeProducerProxy.fromEndpoint(endpoint); |
1736 } | 1789 } |
1737 | 1790 |
1738 | 1791 |
1739 dynamic getBuffer([Function responseFactory = null]) { | 1792 void getBuffer(void callback(core.MojoSharedBuffer buffer)) { |
1740 if (impl != null) { | 1793 if (impl != null) { |
1741 return new Future(() => impl.getBuffer(_MediaPullModeProducerStubControl._
mediaPullModeProducerGetBufferResponseParamsFactory)); | 1794 impl.getBuffer(callback); |
| 1795 return; |
1742 } | 1796 } |
1743 var params = new _MediaPullModeProducerGetBufferParams(); | 1797 var params = new _MediaPullModeProducerGetBufferParams(); |
1744 return ctrl.sendMessageWithRequestId( | 1798 ctrl.sendMessageWithRequestId( |
1745 params, | 1799 params, |
1746 _mediaPullModeProducerMethodGetBufferName, | 1800 _mediaPullModeProducerMethodGetBufferName, |
1747 -1, | 1801 -1, |
1748 bindings.MessageHeader.kMessageExpectsResponse); | 1802 bindings.MessageHeader.kMessageExpectsResponse, |
| 1803 callback); |
1749 } | 1804 } |
1750 dynamic pullPacket(MediaPacket toRelease,[Function responseFactory = null]) { | 1805 void pullPacket(MediaPacket toRelease,void callback(MediaPacket packet)) { |
1751 if (impl != null) { | 1806 if (impl != null) { |
1752 return new Future(() => impl.pullPacket(toRelease,_MediaPullModeProducerSt
ubControl._mediaPullModeProducerPullPacketResponseParamsFactory)); | 1807 impl.pullPacket(toRelease,callback); |
| 1808 return; |
1753 } | 1809 } |
1754 var params = new _MediaPullModeProducerPullPacketParams(); | 1810 var params = new _MediaPullModeProducerPullPacketParams(); |
1755 params.toRelease = toRelease; | 1811 params.toRelease = toRelease; |
1756 return ctrl.sendMessageWithRequestId( | 1812 ctrl.sendMessageWithRequestId( |
1757 params, | 1813 params, |
1758 _mediaPullModeProducerMethodPullPacketName, | 1814 _mediaPullModeProducerMethodPullPacketName, |
1759 -1, | 1815 -1, |
1760 bindings.MessageHeader.kMessageExpectsResponse); | 1816 bindings.MessageHeader.kMessageExpectsResponse, |
| 1817 callback); |
1761 } | 1818 } |
1762 void releasePacket(MediaPacket toRelease) { | 1819 void releasePacket(MediaPacket toRelease) { |
1763 if (impl != null) { | 1820 if (impl != null) { |
1764 impl.releasePacket(toRelease); | 1821 impl.releasePacket(toRelease); |
1765 return; | 1822 return; |
1766 } | 1823 } |
1767 if (!ctrl.isBound) { | 1824 if (!ctrl.isBound) { |
1768 ctrl.proxyError("The Proxy is closed."); | 1825 ctrl.proxyError("The Proxy is closed."); |
1769 return; | 1826 return; |
1770 } | 1827 } |
(...skipping 19 matching lines...) Expand all Loading... |
1790 core.MojoHandle handle, [MediaPullModeProducer impl]) | 1847 core.MojoHandle handle, [MediaPullModeProducer impl]) |
1791 : super.fromHandle(handle, autoBegin: impl != null) { | 1848 : super.fromHandle(handle, autoBegin: impl != null) { |
1792 _impl = impl; | 1849 _impl = impl; |
1793 } | 1850 } |
1794 | 1851 |
1795 _MediaPullModeProducerStubControl.unbound([this._impl]) : super.unbound(); | 1852 _MediaPullModeProducerStubControl.unbound([this._impl]) : super.unbound(); |
1796 | 1853 |
1797 String get serviceName => MediaPullModeProducer.serviceName; | 1854 String get serviceName => MediaPullModeProducer.serviceName; |
1798 | 1855 |
1799 | 1856 |
1800 static MediaPullModeProducerGetBufferResponseParams _mediaPullModeProducerGetB
ufferResponseParamsFactory(core.MojoSharedBuffer buffer) { | 1857 Function _mediaPullModeProducerGetBufferResponseParamsResponder( |
1801 var result = new MediaPullModeProducerGetBufferResponseParams(); | 1858 int requestId) { |
1802 result.buffer = buffer; | 1859 return (core.MojoSharedBuffer buffer) { |
1803 return result; | 1860 var result = new MediaPullModeProducerGetBufferResponseParams(); |
| 1861 result.buffer = buffer; |
| 1862 sendResponse(buildResponseWithId( |
| 1863 result, |
| 1864 _mediaPullModeProducerMethodGetBufferName, |
| 1865 requestId, |
| 1866 bindings.MessageHeader.kMessageIsResponse)); |
| 1867 }; |
1804 } | 1868 } |
1805 static MediaPullModeProducerPullPacketResponseParams _mediaPullModeProducerPul
lPacketResponseParamsFactory(MediaPacket packet) { | 1869 Function _mediaPullModeProducerPullPacketResponseParamsResponder( |
1806 var result = new MediaPullModeProducerPullPacketResponseParams(); | 1870 int requestId) { |
1807 result.packet = packet; | 1871 return (MediaPacket packet) { |
1808 return result; | 1872 var result = new MediaPullModeProducerPullPacketResponseParams(); |
| 1873 result.packet = packet; |
| 1874 sendResponse(buildResponseWithId( |
| 1875 result, |
| 1876 _mediaPullModeProducerMethodPullPacketName, |
| 1877 requestId, |
| 1878 bindings.MessageHeader.kMessageIsResponse)); |
| 1879 }; |
1809 } | 1880 } |
1810 | 1881 |
1811 dynamic handleMessage(bindings.ServiceMessage message) { | 1882 void handleMessage(bindings.ServiceMessage message) { |
1812 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 1883 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
1813 return bindings.ControlMessageHandler.handleMessage(this, | 1884 bindings.ControlMessageHandler.handleMessage( |
1814 0, | 1885 this, 0, message); |
1815 message); | 1886 return; |
1816 } | 1887 } |
1817 if (_impl == null) { | 1888 if (_impl == null) { |
1818 throw new core.MojoApiError("$this has no implementation set"); | 1889 throw new core.MojoApiError("$this has no implementation set"); |
1819 } | 1890 } |
1820 switch (message.header.type) { | 1891 switch (message.header.type) { |
1821 case _mediaPullModeProducerMethodGetBufferName: | 1892 case _mediaPullModeProducerMethodGetBufferName: |
1822 var response = _impl.getBuffer(_mediaPullModeProducerGetBufferResponsePa
ramsFactory); | 1893 _impl.getBuffer(_mediaPullModeProducerGetBufferResponseParamsResponder(m
essage.header.requestId)); |
1823 if (response is Future) { | |
1824 return response.then((response) { | |
1825 if (response != null) { | |
1826 return buildResponseWithId( | |
1827 response, | |
1828 _mediaPullModeProducerMethodGetBufferName, | |
1829 message.header.requestId, | |
1830 bindings.MessageHeader.kMessageIsResponse); | |
1831 } | |
1832 }); | |
1833 } else if (response != null) { | |
1834 return buildResponseWithId( | |
1835 response, | |
1836 _mediaPullModeProducerMethodGetBufferName, | |
1837 message.header.requestId, | |
1838 bindings.MessageHeader.kMessageIsResponse); | |
1839 } | |
1840 break; | 1894 break; |
1841 case _mediaPullModeProducerMethodPullPacketName: | 1895 case _mediaPullModeProducerMethodPullPacketName: |
1842 var params = _MediaPullModeProducerPullPacketParams.deserialize( | 1896 var params = _MediaPullModeProducerPullPacketParams.deserialize( |
1843 message.payload); | 1897 message.payload); |
1844 var response = _impl.pullPacket(params.toRelease,_mediaPullModeProducerP
ullPacketResponseParamsFactory); | 1898 _impl.pullPacket(params.toRelease, _mediaPullModeProducerPullPacketRespo
nseParamsResponder(message.header.requestId)); |
1845 if (response is Future) { | |
1846 return response.then((response) { | |
1847 if (response != null) { | |
1848 return buildResponseWithId( | |
1849 response, | |
1850 _mediaPullModeProducerMethodPullPacketName, | |
1851 message.header.requestId, | |
1852 bindings.MessageHeader.kMessageIsResponse); | |
1853 } | |
1854 }); | |
1855 } else if (response != null) { | |
1856 return buildResponseWithId( | |
1857 response, | |
1858 _mediaPullModeProducerMethodPullPacketName, | |
1859 message.header.requestId, | |
1860 bindings.MessageHeader.kMessageIsResponse); | |
1861 } | |
1862 break; | 1899 break; |
1863 case _mediaPullModeProducerMethodReleasePacketName: | 1900 case _mediaPullModeProducerMethodReleasePacketName: |
1864 var params = _MediaPullModeProducerReleasePacketParams.deserialize( | 1901 var params = _MediaPullModeProducerReleasePacketParams.deserialize( |
1865 message.payload); | 1902 message.payload); |
1866 _impl.releasePacket(params.toRelease); | 1903 _impl.releasePacket(params.toRelease); |
1867 break; | 1904 break; |
1868 default: | 1905 default: |
1869 throw new bindings.MojoCodecError("Unexpected message name"); | 1906 throw new bindings.MojoCodecError("Unexpected message name"); |
1870 break; | 1907 break; |
1871 } | 1908 } |
1872 return null; | |
1873 } | 1909 } |
1874 | 1910 |
1875 MediaPullModeProducer get impl => _impl; | 1911 MediaPullModeProducer get impl => _impl; |
1876 set impl(MediaPullModeProducer d) { | 1912 set impl(MediaPullModeProducer d) { |
1877 if (d == null) { | 1913 if (d == null) { |
1878 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 1914 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
1879 } | 1915 } |
1880 if (isBound && (_impl == null)) { | 1916 if (isBound && (_impl == null)) { |
1881 beginHandlingEvents(); | 1917 beginHandlingEvents(); |
1882 } | 1918 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1916 core.MojoHandle handle, [MediaPullModeProducer impl]) | 1952 core.MojoHandle handle, [MediaPullModeProducer impl]) |
1917 : super(new _MediaPullModeProducerStubControl.fromHandle(handle, impl)); | 1953 : super(new _MediaPullModeProducerStubControl.fromHandle(handle, impl)); |
1918 | 1954 |
1919 static MediaPullModeProducerStub newFromEndpoint( | 1955 static MediaPullModeProducerStub newFromEndpoint( |
1920 core.MojoMessagePipeEndpoint endpoint) { | 1956 core.MojoMessagePipeEndpoint endpoint) { |
1921 assert(endpoint.setDescription("For MediaPullModeProducerStub")); | 1957 assert(endpoint.setDescription("For MediaPullModeProducerStub")); |
1922 return new MediaPullModeProducerStub.fromEndpoint(endpoint); | 1958 return new MediaPullModeProducerStub.fromEndpoint(endpoint); |
1923 } | 1959 } |
1924 | 1960 |
1925 | 1961 |
1926 dynamic getBuffer([Function responseFactory = null]) { | 1962 void getBuffer(void callback(core.MojoSharedBuffer buffer)) { |
1927 return impl.getBuffer(responseFactory); | 1963 return impl.getBuffer(callback); |
1928 } | 1964 } |
1929 dynamic pullPacket(MediaPacket toRelease,[Function responseFactory = null]) { | 1965 void pullPacket(MediaPacket toRelease,void callback(MediaPacket packet)) { |
1930 return impl.pullPacket(toRelease,responseFactory); | 1966 return impl.pullPacket(toRelease,callback); |
1931 } | 1967 } |
1932 void releasePacket(MediaPacket toRelease) { | 1968 void releasePacket(MediaPacket toRelease) { |
1933 return impl.releasePacket(toRelease); | 1969 return impl.releasePacket(toRelease); |
1934 } | 1970 } |
1935 } | 1971 } |
1936 | 1972 |
1937 const int _mediaConsumerMethodSetBufferName = 0; | 1973 const int _mediaConsumerMethodSetBufferName = 0; |
1938 const int _mediaConsumerMethodSendPacketName = 1; | 1974 const int _mediaConsumerMethodSendPacketName = 1; |
1939 const int _mediaConsumerMethodPrimeName = 2; | 1975 const int _mediaConsumerMethodPrimeName = 2; |
1940 const int _mediaConsumerMethodFlushName = 3; | 1976 const int _mediaConsumerMethodFlushName = 3; |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1985 return 'MediaConsumerSendResult.flushed'; | 2021 return 'MediaConsumerSendResult.flushed'; |
1986 default: | 2022 default: |
1987 return null; | 2023 return null; |
1988 } | 2024 } |
1989 } | 2025 } |
1990 | 2026 |
1991 int toJson() => mojoEnumValue; | 2027 int toJson() => mojoEnumValue; |
1992 } | 2028 } |
1993 | 2029 |
1994 class _MediaConsumerServiceDescription implements service_describer.ServiceDescr
iption { | 2030 class _MediaConsumerServiceDescription implements service_describer.ServiceDescr
iption { |
1995 dynamic getTopLevelInterface([Function responseFactory]) => | 2031 void getTopLevelInterface(Function responder) { |
1996 responseFactory(null); | 2032 responder(null); |
| 2033 } |
1997 | 2034 |
1998 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 2035 void getTypeDefinition(String typeKey, Function responder) { |
1999 responseFactory(null); | 2036 responder(null); |
| 2037 } |
2000 | 2038 |
2001 dynamic getAllTypeDefinitions([Function responseFactory]) => | 2039 void getAllTypeDefinitions(Function responder) { |
2002 responseFactory(null); | 2040 responder(null); |
| 2041 } |
2003 } | 2042 } |
2004 | 2043 |
2005 abstract class MediaConsumer { | 2044 abstract class MediaConsumer { |
2006 static const String serviceName = null; | 2045 static const String serviceName = null; |
2007 | 2046 |
2008 static service_describer.ServiceDescription _cachedServiceDescription; | 2047 static service_describer.ServiceDescription _cachedServiceDescription; |
2009 static service_describer.ServiceDescription get serviceDescription { | 2048 static service_describer.ServiceDescription get serviceDescription { |
2010 if (_cachedServiceDescription == null) { | 2049 if (_cachedServiceDescription == null) { |
2011 _cachedServiceDescription = new _MediaConsumerServiceDescription(); | 2050 _cachedServiceDescription = new _MediaConsumerServiceDescription(); |
2012 } | 2051 } |
2013 return _cachedServiceDescription; | 2052 return _cachedServiceDescription; |
2014 } | 2053 } |
2015 | 2054 |
2016 static MediaConsumerProxy connectToService( | 2055 static MediaConsumerProxy connectToService( |
2017 bindings.ServiceConnector s, String url, [String serviceName]) { | 2056 bindings.ServiceConnector s, String url, [String serviceName]) { |
2018 MediaConsumerProxy p = new MediaConsumerProxy.unbound(); | 2057 MediaConsumerProxy p = new MediaConsumerProxy.unbound(); |
2019 String name = serviceName ?? MediaConsumer.serviceName; | 2058 String name = serviceName ?? MediaConsumer.serviceName; |
2020 if ((name == null) || name.isEmpty) { | 2059 if ((name == null) || name.isEmpty) { |
2021 throw new core.MojoApiError( | 2060 throw new core.MojoApiError( |
2022 "If an interface has no ServiceName, then one must be provided."); | 2061 "If an interface has no ServiceName, then one must be provided."); |
2023 } | 2062 } |
2024 s.connectToService(url, p, name); | 2063 s.connectToService(url, p, name); |
2025 return p; | 2064 return p; |
2026 } | 2065 } |
2027 dynamic setBuffer(core.MojoSharedBuffer buffer,[Function responseFactory = nul
l]); | 2066 void setBuffer(core.MojoSharedBuffer buffer,void callback()); |
2028 dynamic sendPacket(MediaPacket packet,[Function responseFactory = null]); | 2067 void sendPacket(MediaPacket packet,void callback(MediaConsumerSendResult resul
t)); |
2029 dynamic prime([Function responseFactory = null]); | 2068 void prime(void callback()); |
2030 dynamic flush([Function responseFactory = null]); | 2069 void flush(void callback()); |
2031 static const int kMaxBufferLen = 4611686018427387903; | 2070 static const int kMaxBufferLen = 4611686018427387903; |
2032 } | 2071 } |
2033 | 2072 |
2034 abstract class MediaConsumerInterface | 2073 abstract class MediaConsumerInterface |
2035 implements bindings.MojoInterface<MediaConsumer>, | 2074 implements bindings.MojoInterface<MediaConsumer>, |
2036 MediaConsumer { | 2075 MediaConsumer { |
2037 factory MediaConsumerInterface([MediaConsumer impl]) => | 2076 factory MediaConsumerInterface([MediaConsumer impl]) => |
2038 new MediaConsumerStub.unbound(impl); | 2077 new MediaConsumerStub.unbound(impl); |
2039 | 2078 |
2040 factory MediaConsumerInterface.fromEndpoint( | 2079 factory MediaConsumerInterface.fromEndpoint( |
(...skipping 30 matching lines...) Expand all Loading... |
2071 | 2110 |
2072 void handleResponse(bindings.ServiceMessage message) { | 2111 void handleResponse(bindings.ServiceMessage message) { |
2073 switch (message.header.type) { | 2112 switch (message.header.type) { |
2074 case _mediaConsumerMethodSetBufferName: | 2113 case _mediaConsumerMethodSetBufferName: |
2075 var r = MediaConsumerSetBufferResponseParams.deserialize( | 2114 var r = MediaConsumerSetBufferResponseParams.deserialize( |
2076 message.payload); | 2115 message.payload); |
2077 if (!message.header.hasRequestId) { | 2116 if (!message.header.hasRequestId) { |
2078 proxyError("Expected a message with a valid request Id."); | 2117 proxyError("Expected a message with a valid request Id."); |
2079 return; | 2118 return; |
2080 } | 2119 } |
2081 Completer c = completerMap[message.header.requestId]; | 2120 Function callback = callbackMap[message.header.requestId]; |
2082 if (c == null) { | 2121 if (callback == null) { |
2083 proxyError( | 2122 proxyError( |
2084 "Message had unknown request Id: ${message.header.requestId}"); | 2123 "Message had unknown request Id: ${message.header.requestId}"); |
2085 return; | 2124 return; |
2086 } | 2125 } |
2087 completerMap.remove(message.header.requestId); | 2126 callbackMap.remove(message.header.requestId); |
2088 if (c.isCompleted) { | 2127 callback(); |
2089 proxyError("Response completer already completed"); | |
2090 return; | |
2091 } | |
2092 c.complete(r); | |
2093 break; | 2128 break; |
2094 case _mediaConsumerMethodSendPacketName: | 2129 case _mediaConsumerMethodSendPacketName: |
2095 var r = MediaConsumerSendPacketResponseParams.deserialize( | 2130 var r = MediaConsumerSendPacketResponseParams.deserialize( |
2096 message.payload); | 2131 message.payload); |
2097 if (!message.header.hasRequestId) { | 2132 if (!message.header.hasRequestId) { |
2098 proxyError("Expected a message with a valid request Id."); | 2133 proxyError("Expected a message with a valid request Id."); |
2099 return; | 2134 return; |
2100 } | 2135 } |
2101 Completer c = completerMap[message.header.requestId]; | 2136 Function callback = callbackMap[message.header.requestId]; |
2102 if (c == null) { | 2137 if (callback == null) { |
2103 proxyError( | 2138 proxyError( |
2104 "Message had unknown request Id: ${message.header.requestId}"); | 2139 "Message had unknown request Id: ${message.header.requestId}"); |
2105 return; | 2140 return; |
2106 } | 2141 } |
2107 completerMap.remove(message.header.requestId); | 2142 callbackMap.remove(message.header.requestId); |
2108 if (c.isCompleted) { | 2143 callback(r.result ); |
2109 proxyError("Response completer already completed"); | |
2110 return; | |
2111 } | |
2112 c.complete(r); | |
2113 break; | 2144 break; |
2114 case _mediaConsumerMethodPrimeName: | 2145 case _mediaConsumerMethodPrimeName: |
2115 var r = MediaConsumerPrimeResponseParams.deserialize( | 2146 var r = MediaConsumerPrimeResponseParams.deserialize( |
2116 message.payload); | 2147 message.payload); |
2117 if (!message.header.hasRequestId) { | 2148 if (!message.header.hasRequestId) { |
2118 proxyError("Expected a message with a valid request Id."); | 2149 proxyError("Expected a message with a valid request Id."); |
2119 return; | 2150 return; |
2120 } | 2151 } |
2121 Completer c = completerMap[message.header.requestId]; | 2152 Function callback = callbackMap[message.header.requestId]; |
2122 if (c == null) { | 2153 if (callback == null) { |
2123 proxyError( | 2154 proxyError( |
2124 "Message had unknown request Id: ${message.header.requestId}"); | 2155 "Message had unknown request Id: ${message.header.requestId}"); |
2125 return; | 2156 return; |
2126 } | 2157 } |
2127 completerMap.remove(message.header.requestId); | 2158 callbackMap.remove(message.header.requestId); |
2128 if (c.isCompleted) { | 2159 callback(); |
2129 proxyError("Response completer already completed"); | |
2130 return; | |
2131 } | |
2132 c.complete(r); | |
2133 break; | 2160 break; |
2134 case _mediaConsumerMethodFlushName: | 2161 case _mediaConsumerMethodFlushName: |
2135 var r = MediaConsumerFlushResponseParams.deserialize( | 2162 var r = MediaConsumerFlushResponseParams.deserialize( |
2136 message.payload); | 2163 message.payload); |
2137 if (!message.header.hasRequestId) { | 2164 if (!message.header.hasRequestId) { |
2138 proxyError("Expected a message with a valid request Id."); | 2165 proxyError("Expected a message with a valid request Id."); |
2139 return; | 2166 return; |
2140 } | 2167 } |
2141 Completer c = completerMap[message.header.requestId]; | 2168 Function callback = callbackMap[message.header.requestId]; |
2142 if (c == null) { | 2169 if (callback == null) { |
2143 proxyError( | 2170 proxyError( |
2144 "Message had unknown request Id: ${message.header.requestId}"); | 2171 "Message had unknown request Id: ${message.header.requestId}"); |
2145 return; | 2172 return; |
2146 } | 2173 } |
2147 completerMap.remove(message.header.requestId); | 2174 callbackMap.remove(message.header.requestId); |
2148 if (c.isCompleted) { | 2175 callback(); |
2149 proxyError("Response completer already completed"); | |
2150 return; | |
2151 } | |
2152 c.complete(r); | |
2153 break; | 2176 break; |
2154 default: | 2177 default: |
2155 proxyError("Unexpected message type: ${message.header.type}"); | 2178 proxyError("Unexpected message type: ${message.header.type}"); |
2156 close(immediate: true); | 2179 close(immediate: true); |
2157 break; | 2180 break; |
2158 } | 2181 } |
2159 } | 2182 } |
2160 | 2183 |
2161 @override | 2184 @override |
2162 String toString() { | 2185 String toString() { |
(...skipping 24 matching lines...) Expand all Loading... |
2187 return newMockedProxy; | 2210 return newMockedProxy; |
2188 } | 2211 } |
2189 | 2212 |
2190 static MediaConsumerProxy newFromEndpoint( | 2213 static MediaConsumerProxy newFromEndpoint( |
2191 core.MojoMessagePipeEndpoint endpoint) { | 2214 core.MojoMessagePipeEndpoint endpoint) { |
2192 assert(endpoint.setDescription("For MediaConsumerProxy")); | 2215 assert(endpoint.setDescription("For MediaConsumerProxy")); |
2193 return new MediaConsumerProxy.fromEndpoint(endpoint); | 2216 return new MediaConsumerProxy.fromEndpoint(endpoint); |
2194 } | 2217 } |
2195 | 2218 |
2196 | 2219 |
2197 dynamic setBuffer(core.MojoSharedBuffer buffer,[Function responseFactory = nul
l]) { | 2220 void setBuffer(core.MojoSharedBuffer buffer,void callback()) { |
2198 if (impl != null) { | 2221 if (impl != null) { |
2199 return new Future(() => impl.setBuffer(buffer,_MediaConsumerStubControl._m
ediaConsumerSetBufferResponseParamsFactory)); | 2222 impl.setBuffer(buffer,callback); |
| 2223 return; |
2200 } | 2224 } |
2201 var params = new _MediaConsumerSetBufferParams(); | 2225 var params = new _MediaConsumerSetBufferParams(); |
2202 params.buffer = buffer; | 2226 params.buffer = buffer; |
2203 return ctrl.sendMessageWithRequestId( | 2227 ctrl.sendMessageWithRequestId( |
2204 params, | 2228 params, |
2205 _mediaConsumerMethodSetBufferName, | 2229 _mediaConsumerMethodSetBufferName, |
2206 -1, | 2230 -1, |
2207 bindings.MessageHeader.kMessageExpectsResponse); | 2231 bindings.MessageHeader.kMessageExpectsResponse, |
| 2232 callback); |
2208 } | 2233 } |
2209 dynamic sendPacket(MediaPacket packet,[Function responseFactory = null]) { | 2234 void sendPacket(MediaPacket packet,void callback(MediaConsumerSendResult resul
t)) { |
2210 if (impl != null) { | 2235 if (impl != null) { |
2211 return new Future(() => impl.sendPacket(packet,_MediaConsumerStubControl._
mediaConsumerSendPacketResponseParamsFactory)); | 2236 impl.sendPacket(packet,callback); |
| 2237 return; |
2212 } | 2238 } |
2213 var params = new _MediaConsumerSendPacketParams(); | 2239 var params = new _MediaConsumerSendPacketParams(); |
2214 params.packet = packet; | 2240 params.packet = packet; |
2215 return ctrl.sendMessageWithRequestId( | 2241 ctrl.sendMessageWithRequestId( |
2216 params, | 2242 params, |
2217 _mediaConsumerMethodSendPacketName, | 2243 _mediaConsumerMethodSendPacketName, |
2218 -1, | 2244 -1, |
2219 bindings.MessageHeader.kMessageExpectsResponse); | 2245 bindings.MessageHeader.kMessageExpectsResponse, |
| 2246 callback); |
2220 } | 2247 } |
2221 dynamic prime([Function responseFactory = null]) { | 2248 void prime(void callback()) { |
2222 if (impl != null) { | 2249 if (impl != null) { |
2223 return new Future(() => impl.prime(_MediaConsumerStubControl._mediaConsume
rPrimeResponseParamsFactory)); | 2250 impl.prime(callback); |
| 2251 return; |
2224 } | 2252 } |
2225 var params = new _MediaConsumerPrimeParams(); | 2253 var params = new _MediaConsumerPrimeParams(); |
2226 return ctrl.sendMessageWithRequestId( | 2254 ctrl.sendMessageWithRequestId( |
2227 params, | 2255 params, |
2228 _mediaConsumerMethodPrimeName, | 2256 _mediaConsumerMethodPrimeName, |
2229 -1, | 2257 -1, |
2230 bindings.MessageHeader.kMessageExpectsResponse); | 2258 bindings.MessageHeader.kMessageExpectsResponse, |
| 2259 callback); |
2231 } | 2260 } |
2232 dynamic flush([Function responseFactory = null]) { | 2261 void flush(void callback()) { |
2233 if (impl != null) { | 2262 if (impl != null) { |
2234 return new Future(() => impl.flush(_MediaConsumerStubControl._mediaConsume
rFlushResponseParamsFactory)); | 2263 impl.flush(callback); |
| 2264 return; |
2235 } | 2265 } |
2236 var params = new _MediaConsumerFlushParams(); | 2266 var params = new _MediaConsumerFlushParams(); |
2237 return ctrl.sendMessageWithRequestId( | 2267 ctrl.sendMessageWithRequestId( |
2238 params, | 2268 params, |
2239 _mediaConsumerMethodFlushName, | 2269 _mediaConsumerMethodFlushName, |
2240 -1, | 2270 -1, |
2241 bindings.MessageHeader.kMessageExpectsResponse); | 2271 bindings.MessageHeader.kMessageExpectsResponse, |
| 2272 callback); |
2242 } | 2273 } |
2243 } | 2274 } |
2244 | 2275 |
2245 class _MediaConsumerStubControl | 2276 class _MediaConsumerStubControl |
2246 extends bindings.StubMessageHandler | 2277 extends bindings.StubMessageHandler |
2247 implements bindings.StubControl<MediaConsumer> { | 2278 implements bindings.StubControl<MediaConsumer> { |
2248 MediaConsumer _impl; | 2279 MediaConsumer _impl; |
2249 | 2280 |
2250 _MediaConsumerStubControl.fromEndpoint( | 2281 _MediaConsumerStubControl.fromEndpoint( |
2251 core.MojoMessagePipeEndpoint endpoint, [MediaConsumer impl]) | 2282 core.MojoMessagePipeEndpoint endpoint, [MediaConsumer impl]) |
2252 : super.fromEndpoint(endpoint, autoBegin: impl != null) { | 2283 : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
2253 _impl = impl; | 2284 _impl = impl; |
2254 } | 2285 } |
2255 | 2286 |
2256 _MediaConsumerStubControl.fromHandle( | 2287 _MediaConsumerStubControl.fromHandle( |
2257 core.MojoHandle handle, [MediaConsumer impl]) | 2288 core.MojoHandle handle, [MediaConsumer impl]) |
2258 : super.fromHandle(handle, autoBegin: impl != null) { | 2289 : super.fromHandle(handle, autoBegin: impl != null) { |
2259 _impl = impl; | 2290 _impl = impl; |
2260 } | 2291 } |
2261 | 2292 |
2262 _MediaConsumerStubControl.unbound([this._impl]) : super.unbound(); | 2293 _MediaConsumerStubControl.unbound([this._impl]) : super.unbound(); |
2263 | 2294 |
2264 String get serviceName => MediaConsumer.serviceName; | 2295 String get serviceName => MediaConsumer.serviceName; |
2265 | 2296 |
2266 | 2297 |
2267 static MediaConsumerSetBufferResponseParams _mediaConsumerSetBufferResponsePar
amsFactory() { | 2298 Function _mediaConsumerSetBufferResponseParamsResponder( |
2268 var result = new MediaConsumerSetBufferResponseParams(); | 2299 int requestId) { |
2269 return result; | 2300 return () { |
| 2301 var result = new MediaConsumerSetBufferResponseParams(); |
| 2302 sendResponse(buildResponseWithId( |
| 2303 result, |
| 2304 _mediaConsumerMethodSetBufferName, |
| 2305 requestId, |
| 2306 bindings.MessageHeader.kMessageIsResponse)); |
| 2307 }; |
2270 } | 2308 } |
2271 static MediaConsumerSendPacketResponseParams _mediaConsumerSendPacketResponseP
aramsFactory(MediaConsumerSendResult result) { | 2309 Function _mediaConsumerSendPacketResponseParamsResponder( |
2272 var result = new MediaConsumerSendPacketResponseParams(); | 2310 int requestId) { |
2273 result.result = result; | 2311 return (MediaConsumerSendResult result) { |
2274 return result; | 2312 var result = new MediaConsumerSendPacketResponseParams(); |
| 2313 result.result = result; |
| 2314 sendResponse(buildResponseWithId( |
| 2315 result, |
| 2316 _mediaConsumerMethodSendPacketName, |
| 2317 requestId, |
| 2318 bindings.MessageHeader.kMessageIsResponse)); |
| 2319 }; |
2275 } | 2320 } |
2276 static MediaConsumerPrimeResponseParams _mediaConsumerPrimeResponseParamsFacto
ry() { | 2321 Function _mediaConsumerPrimeResponseParamsResponder( |
2277 var result = new MediaConsumerPrimeResponseParams(); | 2322 int requestId) { |
2278 return result; | 2323 return () { |
| 2324 var result = new MediaConsumerPrimeResponseParams(); |
| 2325 sendResponse(buildResponseWithId( |
| 2326 result, |
| 2327 _mediaConsumerMethodPrimeName, |
| 2328 requestId, |
| 2329 bindings.MessageHeader.kMessageIsResponse)); |
| 2330 }; |
2279 } | 2331 } |
2280 static MediaConsumerFlushResponseParams _mediaConsumerFlushResponseParamsFacto
ry() { | 2332 Function _mediaConsumerFlushResponseParamsResponder( |
2281 var result = new MediaConsumerFlushResponseParams(); | 2333 int requestId) { |
2282 return result; | 2334 return () { |
| 2335 var result = new MediaConsumerFlushResponseParams(); |
| 2336 sendResponse(buildResponseWithId( |
| 2337 result, |
| 2338 _mediaConsumerMethodFlushName, |
| 2339 requestId, |
| 2340 bindings.MessageHeader.kMessageIsResponse)); |
| 2341 }; |
2283 } | 2342 } |
2284 | 2343 |
2285 dynamic handleMessage(bindings.ServiceMessage message) { | 2344 void handleMessage(bindings.ServiceMessage message) { |
2286 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 2345 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
2287 return bindings.ControlMessageHandler.handleMessage(this, | 2346 bindings.ControlMessageHandler.handleMessage( |
2288 0, | 2347 this, 0, message); |
2289 message); | 2348 return; |
2290 } | 2349 } |
2291 if (_impl == null) { | 2350 if (_impl == null) { |
2292 throw new core.MojoApiError("$this has no implementation set"); | 2351 throw new core.MojoApiError("$this has no implementation set"); |
2293 } | 2352 } |
2294 switch (message.header.type) { | 2353 switch (message.header.type) { |
2295 case _mediaConsumerMethodSetBufferName: | 2354 case _mediaConsumerMethodSetBufferName: |
2296 var params = _MediaConsumerSetBufferParams.deserialize( | 2355 var params = _MediaConsumerSetBufferParams.deserialize( |
2297 message.payload); | 2356 message.payload); |
2298 var response = _impl.setBuffer(params.buffer,_mediaConsumerSetBufferResp
onseParamsFactory); | 2357 _impl.setBuffer(params.buffer, _mediaConsumerSetBufferResponseParamsResp
onder(message.header.requestId)); |
2299 if (response is Future) { | |
2300 return response.then((response) { | |
2301 if (response != null) { | |
2302 return buildResponseWithId( | |
2303 response, | |
2304 _mediaConsumerMethodSetBufferName, | |
2305 message.header.requestId, | |
2306 bindings.MessageHeader.kMessageIsResponse); | |
2307 } | |
2308 }); | |
2309 } else if (response != null) { | |
2310 return buildResponseWithId( | |
2311 response, | |
2312 _mediaConsumerMethodSetBufferName, | |
2313 message.header.requestId, | |
2314 bindings.MessageHeader.kMessageIsResponse); | |
2315 } | |
2316 break; | 2358 break; |
2317 case _mediaConsumerMethodSendPacketName: | 2359 case _mediaConsumerMethodSendPacketName: |
2318 var params = _MediaConsumerSendPacketParams.deserialize( | 2360 var params = _MediaConsumerSendPacketParams.deserialize( |
2319 message.payload); | 2361 message.payload); |
2320 var response = _impl.sendPacket(params.packet,_mediaConsumerSendPacketRe
sponseParamsFactory); | 2362 _impl.sendPacket(params.packet, _mediaConsumerSendPacketResponseParamsRe
sponder(message.header.requestId)); |
2321 if (response is Future) { | |
2322 return response.then((response) { | |
2323 if (response != null) { | |
2324 return buildResponseWithId( | |
2325 response, | |
2326 _mediaConsumerMethodSendPacketName, | |
2327 message.header.requestId, | |
2328 bindings.MessageHeader.kMessageIsResponse); | |
2329 } | |
2330 }); | |
2331 } else if (response != null) { | |
2332 return buildResponseWithId( | |
2333 response, | |
2334 _mediaConsumerMethodSendPacketName, | |
2335 message.header.requestId, | |
2336 bindings.MessageHeader.kMessageIsResponse); | |
2337 } | |
2338 break; | 2363 break; |
2339 case _mediaConsumerMethodPrimeName: | 2364 case _mediaConsumerMethodPrimeName: |
2340 var response = _impl.prime(_mediaConsumerPrimeResponseParamsFactory); | 2365 _impl.prime(_mediaConsumerPrimeResponseParamsResponder(message.header.re
questId)); |
2341 if (response is Future) { | |
2342 return response.then((response) { | |
2343 if (response != null) { | |
2344 return buildResponseWithId( | |
2345 response, | |
2346 _mediaConsumerMethodPrimeName, | |
2347 message.header.requestId, | |
2348 bindings.MessageHeader.kMessageIsResponse); | |
2349 } | |
2350 }); | |
2351 } else if (response != null) { | |
2352 return buildResponseWithId( | |
2353 response, | |
2354 _mediaConsumerMethodPrimeName, | |
2355 message.header.requestId, | |
2356 bindings.MessageHeader.kMessageIsResponse); | |
2357 } | |
2358 break; | 2366 break; |
2359 case _mediaConsumerMethodFlushName: | 2367 case _mediaConsumerMethodFlushName: |
2360 var response = _impl.flush(_mediaConsumerFlushResponseParamsFactory); | 2368 _impl.flush(_mediaConsumerFlushResponseParamsResponder(message.header.re
questId)); |
2361 if (response is Future) { | |
2362 return response.then((response) { | |
2363 if (response != null) { | |
2364 return buildResponseWithId( | |
2365 response, | |
2366 _mediaConsumerMethodFlushName, | |
2367 message.header.requestId, | |
2368 bindings.MessageHeader.kMessageIsResponse); | |
2369 } | |
2370 }); | |
2371 } else if (response != null) { | |
2372 return buildResponseWithId( | |
2373 response, | |
2374 _mediaConsumerMethodFlushName, | |
2375 message.header.requestId, | |
2376 bindings.MessageHeader.kMessageIsResponse); | |
2377 } | |
2378 break; | 2369 break; |
2379 default: | 2370 default: |
2380 throw new bindings.MojoCodecError("Unexpected message name"); | 2371 throw new bindings.MojoCodecError("Unexpected message name"); |
2381 break; | 2372 break; |
2382 } | 2373 } |
2383 return null; | |
2384 } | 2374 } |
2385 | 2375 |
2386 MediaConsumer get impl => _impl; | 2376 MediaConsumer get impl => _impl; |
2387 set impl(MediaConsumer d) { | 2377 set impl(MediaConsumer d) { |
2388 if (d == null) { | 2378 if (d == null) { |
2389 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 2379 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
2390 } | 2380 } |
2391 if (isBound && (_impl == null)) { | 2381 if (isBound && (_impl == null)) { |
2392 beginHandlingEvents(); | 2382 beginHandlingEvents(); |
2393 } | 2383 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2427 core.MojoHandle handle, [MediaConsumer impl]) | 2417 core.MojoHandle handle, [MediaConsumer impl]) |
2428 : super(new _MediaConsumerStubControl.fromHandle(handle, impl)); | 2418 : super(new _MediaConsumerStubControl.fromHandle(handle, impl)); |
2429 | 2419 |
2430 static MediaConsumerStub newFromEndpoint( | 2420 static MediaConsumerStub newFromEndpoint( |
2431 core.MojoMessagePipeEndpoint endpoint) { | 2421 core.MojoMessagePipeEndpoint endpoint) { |
2432 assert(endpoint.setDescription("For MediaConsumerStub")); | 2422 assert(endpoint.setDescription("For MediaConsumerStub")); |
2433 return new MediaConsumerStub.fromEndpoint(endpoint); | 2423 return new MediaConsumerStub.fromEndpoint(endpoint); |
2434 } | 2424 } |
2435 | 2425 |
2436 | 2426 |
2437 dynamic setBuffer(core.MojoSharedBuffer buffer,[Function responseFactory = nul
l]) { | 2427 void setBuffer(core.MojoSharedBuffer buffer,void callback()) { |
2438 return impl.setBuffer(buffer,responseFactory); | 2428 return impl.setBuffer(buffer,callback); |
2439 } | 2429 } |
2440 dynamic sendPacket(MediaPacket packet,[Function responseFactory = null]) { | 2430 void sendPacket(MediaPacket packet,void callback(MediaConsumerSendResult resul
t)) { |
2441 return impl.sendPacket(packet,responseFactory); | 2431 return impl.sendPacket(packet,callback); |
2442 } | 2432 } |
2443 dynamic prime([Function responseFactory = null]) { | 2433 void prime(void callback()) { |
2444 return impl.prime(responseFactory); | 2434 return impl.prime(callback); |
2445 } | 2435 } |
2446 dynamic flush([Function responseFactory = null]) { | 2436 void flush(void callback()) { |
2447 return impl.flush(responseFactory); | 2437 return impl.flush(callback); |
2448 } | 2438 } |
2449 } | 2439 } |
2450 | 2440 |
2451 | 2441 |
2452 | 2442 |
OLD | NEW |