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 terminal_mojom; | 4 library terminal_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_services/mojo/files/file.mojom.dart' as file_mojom; | 9 import 'package:mojo_services/mojo/files/file.mojom.dart' as file_mojom; |
10 import 'package:mojo_services/mojo/files/types.mojom.dart' as types_mojom; | 10 import 'package:mojo_services/mojo/files/types.mojom.dart' as types_mojom; |
11 import 'package:mojo_services/mojo/terminal/terminal_client.mojom.dart' as termi
nal_client_mojom; | 11 import 'package:mojo_services/mojo/terminal/terminal_client.mojom.dart' as termi
nal_client_mojom; |
12 | 12 |
13 | 13 |
14 | 14 |
15 class _TerminalConnectParams extends bindings.Struct { | 15 class _TerminalConnectParams extends bindings.Struct { |
16 static const List<bindings.StructDataHeader> kVersions = const [ | 16 static const List<bindings.StructDataHeader> kVersions = const [ |
17 const bindings.StructDataHeader(16, 0) | 17 const bindings.StructDataHeader(16, 0) |
18 ]; | 18 ]; |
19 file_mojom.FileInterfaceRequest terminalFile = null; | 19 file_mojom.FileInterfaceRequest terminalFile = null; |
20 bool force = false; | 20 bool force = false; |
21 | 21 |
22 _TerminalConnectParams() : super(kVersions.last.size); | 22 _TerminalConnectParams() : super(kVersions.last.size); |
23 | 23 |
| 24 _TerminalConnectParams.init( |
| 25 file_mojom.FileInterfaceRequest this.terminalFile, |
| 26 bool this.force |
| 27 ) : super(kVersions.last.size); |
| 28 |
24 static _TerminalConnectParams deserialize(bindings.Message message) { | 29 static _TerminalConnectParams 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 _TerminalConnectParams decode(bindings.Decoder decoder0) { | 38 static _TerminalConnectParams decode(bindings.Decoder decoder0) { |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
97 | 102 |
98 | 103 |
99 class TerminalConnectResponseParams extends bindings.Struct { | 104 class TerminalConnectResponseParams extends bindings.Struct { |
100 static const List<bindings.StructDataHeader> kVersions = const [ | 105 static const List<bindings.StructDataHeader> kVersions = const [ |
101 const bindings.StructDataHeader(16, 0) | 106 const bindings.StructDataHeader(16, 0) |
102 ]; | 107 ]; |
103 types_mojom.Error error = null; | 108 types_mojom.Error error = null; |
104 | 109 |
105 TerminalConnectResponseParams() : super(kVersions.last.size); | 110 TerminalConnectResponseParams() : super(kVersions.last.size); |
106 | 111 |
| 112 TerminalConnectResponseParams.init( |
| 113 types_mojom.Error this.error |
| 114 ) : super(kVersions.last.size); |
| 115 |
107 static TerminalConnectResponseParams deserialize(bindings.Message message) { | 116 static TerminalConnectResponseParams deserialize(bindings.Message message) { |
108 var decoder = new bindings.Decoder(message); | 117 var decoder = new bindings.Decoder(message); |
109 var result = decode(decoder); | 118 var result = decode(decoder); |
110 if (decoder.excessHandles != null) { | 119 if (decoder.excessHandles != null) { |
111 decoder.excessHandles.forEach((h) => h.close()); | 120 decoder.excessHandles.forEach((h) => h.close()); |
112 } | 121 } |
113 return result; | 122 return result; |
114 } | 123 } |
115 | 124 |
116 static TerminalConnectResponseParams decode(bindings.Decoder decoder0) { | 125 static TerminalConnectResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
174 | 183 |
175 class _TerminalConnectToClientParams extends bindings.Struct { | 184 class _TerminalConnectToClientParams extends bindings.Struct { |
176 static const List<bindings.StructDataHeader> kVersions = const [ | 185 static const List<bindings.StructDataHeader> kVersions = const [ |
177 const bindings.StructDataHeader(24, 0) | 186 const bindings.StructDataHeader(24, 0) |
178 ]; | 187 ]; |
179 terminal_client_mojom.TerminalClientInterface terminalClient = null; | 188 terminal_client_mojom.TerminalClientInterface terminalClient = null; |
180 bool force = false; | 189 bool force = false; |
181 | 190 |
182 _TerminalConnectToClientParams() : super(kVersions.last.size); | 191 _TerminalConnectToClientParams() : super(kVersions.last.size); |
183 | 192 |
| 193 _TerminalConnectToClientParams.init( |
| 194 terminal_client_mojom.TerminalClientInterface this.terminalClient, |
| 195 bool this.force |
| 196 ) : super(kVersions.last.size); |
| 197 |
184 static _TerminalConnectToClientParams deserialize(bindings.Message message) { | 198 static _TerminalConnectToClientParams deserialize(bindings.Message message) { |
185 var decoder = new bindings.Decoder(message); | 199 var decoder = new bindings.Decoder(message); |
186 var result = decode(decoder); | 200 var result = decode(decoder); |
187 if (decoder.excessHandles != null) { | 201 if (decoder.excessHandles != null) { |
188 decoder.excessHandles.forEach((h) => h.close()); | 202 decoder.excessHandles.forEach((h) => h.close()); |
189 } | 203 } |
190 return result; | 204 return result; |
191 } | 205 } |
192 | 206 |
193 static _TerminalConnectToClientParams decode(bindings.Decoder decoder0) { | 207 static _TerminalConnectToClientParams decode(bindings.Decoder decoder0) { |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
257 | 271 |
258 | 272 |
259 class TerminalConnectToClientResponseParams extends bindings.Struct { | 273 class TerminalConnectToClientResponseParams extends bindings.Struct { |
260 static const List<bindings.StructDataHeader> kVersions = const [ | 274 static const List<bindings.StructDataHeader> kVersions = const [ |
261 const bindings.StructDataHeader(16, 0) | 275 const bindings.StructDataHeader(16, 0) |
262 ]; | 276 ]; |
263 types_mojom.Error error = null; | 277 types_mojom.Error error = null; |
264 | 278 |
265 TerminalConnectToClientResponseParams() : super(kVersions.last.size); | 279 TerminalConnectToClientResponseParams() : super(kVersions.last.size); |
266 | 280 |
| 281 TerminalConnectToClientResponseParams.init( |
| 282 types_mojom.Error this.error |
| 283 ) : super(kVersions.last.size); |
| 284 |
267 static TerminalConnectToClientResponseParams deserialize(bindings.Message mess
age) { | 285 static TerminalConnectToClientResponseParams deserialize(bindings.Message mess
age) { |
268 var decoder = new bindings.Decoder(message); | 286 var decoder = new bindings.Decoder(message); |
269 var result = decode(decoder); | 287 var result = decode(decoder); |
270 if (decoder.excessHandles != null) { | 288 if (decoder.excessHandles != null) { |
271 decoder.excessHandles.forEach((h) => h.close()); | 289 decoder.excessHandles.forEach((h) => h.close()); |
272 } | 290 } |
273 return result; | 291 return result; |
274 } | 292 } |
275 | 293 |
276 static TerminalConnectToClientResponseParams decode(bindings.Decoder decoder0)
{ | 294 static TerminalConnectToClientResponseParams decode(bindings.Decoder decoder0)
{ |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
332 } | 350 } |
333 | 351 |
334 | 352 |
335 class _TerminalGetSizeParams extends bindings.Struct { | 353 class _TerminalGetSizeParams extends bindings.Struct { |
336 static const List<bindings.StructDataHeader> kVersions = const [ | 354 static const List<bindings.StructDataHeader> kVersions = const [ |
337 const bindings.StructDataHeader(8, 0) | 355 const bindings.StructDataHeader(8, 0) |
338 ]; | 356 ]; |
339 | 357 |
340 _TerminalGetSizeParams() : super(kVersions.last.size); | 358 _TerminalGetSizeParams() : super(kVersions.last.size); |
341 | 359 |
| 360 _TerminalGetSizeParams.init( |
| 361 ) : super(kVersions.last.size); |
| 362 |
342 static _TerminalGetSizeParams deserialize(bindings.Message message) { | 363 static _TerminalGetSizeParams deserialize(bindings.Message message) { |
343 var decoder = new bindings.Decoder(message); | 364 var decoder = new bindings.Decoder(message); |
344 var result = decode(decoder); | 365 var result = decode(decoder); |
345 if (decoder.excessHandles != null) { | 366 if (decoder.excessHandles != null) { |
346 decoder.excessHandles.forEach((h) => h.close()); | 367 decoder.excessHandles.forEach((h) => h.close()); |
347 } | 368 } |
348 return result; | 369 return result; |
349 } | 370 } |
350 | 371 |
351 static _TerminalGetSizeParams decode(bindings.Decoder decoder0) { | 372 static _TerminalGetSizeParams decode(bindings.Decoder decoder0) { |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
393 class TerminalGetSizeResponseParams extends bindings.Struct { | 414 class TerminalGetSizeResponseParams extends bindings.Struct { |
394 static const List<bindings.StructDataHeader> kVersions = const [ | 415 static const List<bindings.StructDataHeader> kVersions = const [ |
395 const bindings.StructDataHeader(24, 0) | 416 const bindings.StructDataHeader(24, 0) |
396 ]; | 417 ]; |
397 types_mojom.Error error = null; | 418 types_mojom.Error error = null; |
398 int rows = 0; | 419 int rows = 0; |
399 int columns = 0; | 420 int columns = 0; |
400 | 421 |
401 TerminalGetSizeResponseParams() : super(kVersions.last.size); | 422 TerminalGetSizeResponseParams() : super(kVersions.last.size); |
402 | 423 |
| 424 TerminalGetSizeResponseParams.init( |
| 425 types_mojom.Error this.error, |
| 426 int this.rows, |
| 427 int this.columns |
| 428 ) : super(kVersions.last.size); |
| 429 |
403 static TerminalGetSizeResponseParams deserialize(bindings.Message message) { | 430 static TerminalGetSizeResponseParams deserialize(bindings.Message message) { |
404 var decoder = new bindings.Decoder(message); | 431 var decoder = new bindings.Decoder(message); |
405 var result = decode(decoder); | 432 var result = decode(decoder); |
406 if (decoder.excessHandles != null) { | 433 if (decoder.excessHandles != null) { |
407 decoder.excessHandles.forEach((h) => h.close()); | 434 decoder.excessHandles.forEach((h) => h.close()); |
408 } | 435 } |
409 return result; | 436 return result; |
410 } | 437 } |
411 | 438 |
412 static TerminalGetSizeResponseParams decode(bindings.Decoder decoder0) { | 439 static TerminalGetSizeResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
497 class _TerminalSetSizeParams extends bindings.Struct { | 524 class _TerminalSetSizeParams extends bindings.Struct { |
498 static const List<bindings.StructDataHeader> kVersions = const [ | 525 static const List<bindings.StructDataHeader> kVersions = const [ |
499 const bindings.StructDataHeader(24, 0) | 526 const bindings.StructDataHeader(24, 0) |
500 ]; | 527 ]; |
501 int rows = 0; | 528 int rows = 0; |
502 int columns = 0; | 529 int columns = 0; |
503 bool reset = false; | 530 bool reset = false; |
504 | 531 |
505 _TerminalSetSizeParams() : super(kVersions.last.size); | 532 _TerminalSetSizeParams() : super(kVersions.last.size); |
506 | 533 |
| 534 _TerminalSetSizeParams.init( |
| 535 int this.rows, |
| 536 int this.columns, |
| 537 bool this.reset |
| 538 ) : super(kVersions.last.size); |
| 539 |
507 static _TerminalSetSizeParams deserialize(bindings.Message message) { | 540 static _TerminalSetSizeParams deserialize(bindings.Message message) { |
508 var decoder = new bindings.Decoder(message); | 541 var decoder = new bindings.Decoder(message); |
509 var result = decode(decoder); | 542 var result = decode(decoder); |
510 if (decoder.excessHandles != null) { | 543 if (decoder.excessHandles != null) { |
511 decoder.excessHandles.forEach((h) => h.close()); | 544 decoder.excessHandles.forEach((h) => h.close()); |
512 } | 545 } |
513 return result; | 546 return result; |
514 } | 547 } |
515 | 548 |
516 static _TerminalSetSizeParams decode(bindings.Decoder decoder0) { | 549 static _TerminalSetSizeParams decode(bindings.Decoder decoder0) { |
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
597 class TerminalSetSizeResponseParams extends bindings.Struct { | 630 class TerminalSetSizeResponseParams extends bindings.Struct { |
598 static const List<bindings.StructDataHeader> kVersions = const [ | 631 static const List<bindings.StructDataHeader> kVersions = const [ |
599 const bindings.StructDataHeader(24, 0) | 632 const bindings.StructDataHeader(24, 0) |
600 ]; | 633 ]; |
601 types_mojom.Error error = null; | 634 types_mojom.Error error = null; |
602 int rows = 0; | 635 int rows = 0; |
603 int columns = 0; | 636 int columns = 0; |
604 | 637 |
605 TerminalSetSizeResponseParams() : super(kVersions.last.size); | 638 TerminalSetSizeResponseParams() : super(kVersions.last.size); |
606 | 639 |
| 640 TerminalSetSizeResponseParams.init( |
| 641 types_mojom.Error this.error, |
| 642 int this.rows, |
| 643 int this.columns |
| 644 ) : super(kVersions.last.size); |
| 645 |
607 static TerminalSetSizeResponseParams deserialize(bindings.Message message) { | 646 static TerminalSetSizeResponseParams deserialize(bindings.Message message) { |
608 var decoder = new bindings.Decoder(message); | 647 var decoder = new bindings.Decoder(message); |
609 var result = decode(decoder); | 648 var result = decode(decoder); |
610 if (decoder.excessHandles != null) { | 649 if (decoder.excessHandles != null) { |
611 decoder.excessHandles.forEach((h) => h.close()); | 650 decoder.excessHandles.forEach((h) => h.close()); |
612 } | 651 } |
613 return result; | 652 return result; |
614 } | 653 } |
615 | 654 |
616 static TerminalSetSizeResponseParams decode(bindings.Decoder decoder0) { | 655 static TerminalSetSizeResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
696 return map; | 735 return map; |
697 } | 736 } |
698 } | 737 } |
699 | 738 |
700 const int _terminalMethodConnectName = 0; | 739 const int _terminalMethodConnectName = 0; |
701 const int _terminalMethodConnectToClientName = 1; | 740 const int _terminalMethodConnectToClientName = 1; |
702 const int _terminalMethodGetSizeName = 2; | 741 const int _terminalMethodGetSizeName = 2; |
703 const int _terminalMethodSetSizeName = 3; | 742 const int _terminalMethodSetSizeName = 3; |
704 | 743 |
705 class _TerminalServiceDescription implements service_describer.ServiceDescriptio
n { | 744 class _TerminalServiceDescription implements service_describer.ServiceDescriptio
n { |
706 dynamic getTopLevelInterface([Function responseFactory]) => | 745 void getTopLevelInterface(Function responder) { |
707 responseFactory(null); | 746 responder(null); |
| 747 } |
708 | 748 |
709 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 749 void getTypeDefinition(String typeKey, Function responder) { |
710 responseFactory(null); | 750 responder(null); |
| 751 } |
711 | 752 |
712 dynamic getAllTypeDefinitions([Function responseFactory]) => | 753 void getAllTypeDefinitions(Function responder) { |
713 responseFactory(null); | 754 responder(null); |
| 755 } |
714 } | 756 } |
715 | 757 |
716 abstract class Terminal { | 758 abstract class Terminal { |
717 static const String serviceName = "mojo::terminal::Terminal"; | 759 static const String serviceName = "mojo::terminal::Terminal"; |
718 | 760 |
719 static service_describer.ServiceDescription _cachedServiceDescription; | 761 static service_describer.ServiceDescription _cachedServiceDescription; |
720 static service_describer.ServiceDescription get serviceDescription { | 762 static service_describer.ServiceDescription get serviceDescription { |
721 if (_cachedServiceDescription == null) { | 763 if (_cachedServiceDescription == null) { |
722 _cachedServiceDescription = new _TerminalServiceDescription(); | 764 _cachedServiceDescription = new _TerminalServiceDescription(); |
723 } | 765 } |
724 return _cachedServiceDescription; | 766 return _cachedServiceDescription; |
725 } | 767 } |
726 | 768 |
727 static TerminalProxy connectToService( | 769 static TerminalProxy connectToService( |
728 bindings.ServiceConnector s, String url, [String serviceName]) { | 770 bindings.ServiceConnector s, String url, [String serviceName]) { |
729 TerminalProxy p = new TerminalProxy.unbound(); | 771 TerminalProxy p = new TerminalProxy.unbound(); |
730 String name = serviceName ?? Terminal.serviceName; | 772 String name = serviceName ?? Terminal.serviceName; |
731 if ((name == null) || name.isEmpty) { | 773 if ((name == null) || name.isEmpty) { |
732 throw new core.MojoApiError( | 774 throw new core.MojoApiError( |
733 "If an interface has no ServiceName, then one must be provided."); | 775 "If an interface has no ServiceName, then one must be provided."); |
734 } | 776 } |
735 s.connectToService(url, p, name); | 777 s.connectToService(url, p, name); |
736 return p; | 778 return p; |
737 } | 779 } |
738 dynamic connect(file_mojom.FileInterfaceRequest terminalFile,bool force,[Funct
ion responseFactory = null]); | 780 void connect(file_mojom.FileInterfaceRequest terminalFile,bool force,void call
back(types_mojom.Error error)); |
739 dynamic connectToClient(terminal_client_mojom.TerminalClientInterface terminal
Client,bool force,[Function responseFactory = null]); | 781 void connectToClient(terminal_client_mojom.TerminalClientInterface terminalCli
ent,bool force,void callback(types_mojom.Error error)); |
740 dynamic getSize([Function responseFactory = null]); | 782 void getSize(void callback(types_mojom.Error error, int rows, int columns)); |
741 dynamic setSize(int rows,int columns,bool reset,[Function responseFactory = nu
ll]); | 783 void setSize(int rows,int columns,bool reset,void callback(types_mojom.Error e
rror, int rows, int columns)); |
742 } | 784 } |
743 | 785 |
744 abstract class TerminalInterface | 786 abstract class TerminalInterface |
745 implements bindings.MojoInterface<Terminal>, | 787 implements bindings.MojoInterface<Terminal>, |
746 Terminal { | 788 Terminal { |
747 factory TerminalInterface([Terminal impl]) => | 789 factory TerminalInterface([Terminal impl]) => |
748 new TerminalStub.unbound(impl); | 790 new TerminalStub.unbound(impl); |
749 | 791 |
750 factory TerminalInterface.fromEndpoint( | 792 factory TerminalInterface.fromEndpoint( |
751 core.MojoMessagePipeEndpoint endpoint, | 793 core.MojoMessagePipeEndpoint endpoint, |
(...skipping 29 matching lines...) Expand all Loading... |
781 | 823 |
782 void handleResponse(bindings.ServiceMessage message) { | 824 void handleResponse(bindings.ServiceMessage message) { |
783 switch (message.header.type) { | 825 switch (message.header.type) { |
784 case _terminalMethodConnectName: | 826 case _terminalMethodConnectName: |
785 var r = TerminalConnectResponseParams.deserialize( | 827 var r = TerminalConnectResponseParams.deserialize( |
786 message.payload); | 828 message.payload); |
787 if (!message.header.hasRequestId) { | 829 if (!message.header.hasRequestId) { |
788 proxyError("Expected a message with a valid request Id."); | 830 proxyError("Expected a message with a valid request Id."); |
789 return; | 831 return; |
790 } | 832 } |
791 Completer c = completerMap[message.header.requestId]; | 833 Function callback = callbackMap[message.header.requestId]; |
792 if (c == null) { | 834 if (callback == null) { |
793 proxyError( | 835 proxyError( |
794 "Message had unknown request Id: ${message.header.requestId}"); | 836 "Message had unknown request Id: ${message.header.requestId}"); |
795 return; | 837 return; |
796 } | 838 } |
797 completerMap.remove(message.header.requestId); | 839 callbackMap.remove(message.header.requestId); |
798 if (c.isCompleted) { | 840 callback(r.error ); |
799 proxyError("Response completer already completed"); | |
800 return; | |
801 } | |
802 c.complete(r); | |
803 break; | 841 break; |
804 case _terminalMethodConnectToClientName: | 842 case _terminalMethodConnectToClientName: |
805 var r = TerminalConnectToClientResponseParams.deserialize( | 843 var r = TerminalConnectToClientResponseParams.deserialize( |
806 message.payload); | 844 message.payload); |
807 if (!message.header.hasRequestId) { | 845 if (!message.header.hasRequestId) { |
808 proxyError("Expected a message with a valid request Id."); | 846 proxyError("Expected a message with a valid request Id."); |
809 return; | 847 return; |
810 } | 848 } |
811 Completer c = completerMap[message.header.requestId]; | 849 Function callback = callbackMap[message.header.requestId]; |
812 if (c == null) { | 850 if (callback == null) { |
813 proxyError( | 851 proxyError( |
814 "Message had unknown request Id: ${message.header.requestId}"); | 852 "Message had unknown request Id: ${message.header.requestId}"); |
815 return; | 853 return; |
816 } | 854 } |
817 completerMap.remove(message.header.requestId); | 855 callbackMap.remove(message.header.requestId); |
818 if (c.isCompleted) { | 856 callback(r.error ); |
819 proxyError("Response completer already completed"); | |
820 return; | |
821 } | |
822 c.complete(r); | |
823 break; | 857 break; |
824 case _terminalMethodGetSizeName: | 858 case _terminalMethodGetSizeName: |
825 var r = TerminalGetSizeResponseParams.deserialize( | 859 var r = TerminalGetSizeResponseParams.deserialize( |
826 message.payload); | 860 message.payload); |
827 if (!message.header.hasRequestId) { | 861 if (!message.header.hasRequestId) { |
828 proxyError("Expected a message with a valid request Id."); | 862 proxyError("Expected a message with a valid request Id."); |
829 return; | 863 return; |
830 } | 864 } |
831 Completer c = completerMap[message.header.requestId]; | 865 Function callback = callbackMap[message.header.requestId]; |
832 if (c == null) { | 866 if (callback == null) { |
833 proxyError( | 867 proxyError( |
834 "Message had unknown request Id: ${message.header.requestId}"); | 868 "Message had unknown request Id: ${message.header.requestId}"); |
835 return; | 869 return; |
836 } | 870 } |
837 completerMap.remove(message.header.requestId); | 871 callbackMap.remove(message.header.requestId); |
838 if (c.isCompleted) { | 872 callback(r.error , r.rows , r.columns ); |
839 proxyError("Response completer already completed"); | |
840 return; | |
841 } | |
842 c.complete(r); | |
843 break; | 873 break; |
844 case _terminalMethodSetSizeName: | 874 case _terminalMethodSetSizeName: |
845 var r = TerminalSetSizeResponseParams.deserialize( | 875 var r = TerminalSetSizeResponseParams.deserialize( |
846 message.payload); | 876 message.payload); |
847 if (!message.header.hasRequestId) { | 877 if (!message.header.hasRequestId) { |
848 proxyError("Expected a message with a valid request Id."); | 878 proxyError("Expected a message with a valid request Id."); |
849 return; | 879 return; |
850 } | 880 } |
851 Completer c = completerMap[message.header.requestId]; | 881 Function callback = callbackMap[message.header.requestId]; |
852 if (c == null) { | 882 if (callback == null) { |
853 proxyError( | 883 proxyError( |
854 "Message had unknown request Id: ${message.header.requestId}"); | 884 "Message had unknown request Id: ${message.header.requestId}"); |
855 return; | 885 return; |
856 } | 886 } |
857 completerMap.remove(message.header.requestId); | 887 callbackMap.remove(message.header.requestId); |
858 if (c.isCompleted) { | 888 callback(r.error , r.rows , r.columns ); |
859 proxyError("Response completer already completed"); | |
860 return; | |
861 } | |
862 c.complete(r); | |
863 break; | 889 break; |
864 default: | 890 default: |
865 proxyError("Unexpected message type: ${message.header.type}"); | 891 proxyError("Unexpected message type: ${message.header.type}"); |
866 close(immediate: true); | 892 close(immediate: true); |
867 break; | 893 break; |
868 } | 894 } |
869 } | 895 } |
870 | 896 |
871 @override | 897 @override |
872 String toString() { | 898 String toString() { |
(...skipping 24 matching lines...) Expand all Loading... |
897 return newMockedProxy; | 923 return newMockedProxy; |
898 } | 924 } |
899 | 925 |
900 static TerminalProxy newFromEndpoint( | 926 static TerminalProxy newFromEndpoint( |
901 core.MojoMessagePipeEndpoint endpoint) { | 927 core.MojoMessagePipeEndpoint endpoint) { |
902 assert(endpoint.setDescription("For TerminalProxy")); | 928 assert(endpoint.setDescription("For TerminalProxy")); |
903 return new TerminalProxy.fromEndpoint(endpoint); | 929 return new TerminalProxy.fromEndpoint(endpoint); |
904 } | 930 } |
905 | 931 |
906 | 932 |
907 dynamic connect(file_mojom.FileInterfaceRequest terminalFile,bool force,[Funct
ion responseFactory = null]) { | 933 void connect(file_mojom.FileInterfaceRequest terminalFile,bool force,void call
back(types_mojom.Error error)) { |
908 if (impl != null) { | 934 if (impl != null) { |
909 return new Future(() => impl.connect(terminalFile,force,_TerminalStubContr
ol._terminalConnectResponseParamsFactory)); | 935 impl.connect(terminalFile,force,callback); |
| 936 return; |
910 } | 937 } |
911 var params = new _TerminalConnectParams(); | 938 var params = new _TerminalConnectParams(); |
912 params.terminalFile = terminalFile; | 939 params.terminalFile = terminalFile; |
913 params.force = force; | 940 params.force = force; |
914 return ctrl.sendMessageWithRequestId( | 941 ctrl.sendMessageWithRequestId( |
915 params, | 942 params, |
916 _terminalMethodConnectName, | 943 _terminalMethodConnectName, |
917 -1, | 944 -1, |
918 bindings.MessageHeader.kMessageExpectsResponse); | 945 bindings.MessageHeader.kMessageExpectsResponse, |
| 946 callback); |
919 } | 947 } |
920 dynamic connectToClient(terminal_client_mojom.TerminalClientInterface terminal
Client,bool force,[Function responseFactory = null]) { | 948 void connectToClient(terminal_client_mojom.TerminalClientInterface terminalCli
ent,bool force,void callback(types_mojom.Error error)) { |
921 if (impl != null) { | 949 if (impl != null) { |
922 return new Future(() => impl.connectToClient(terminalClient,force,_Termina
lStubControl._terminalConnectToClientResponseParamsFactory)); | 950 impl.connectToClient(terminalClient,force,callback); |
| 951 return; |
923 } | 952 } |
924 var params = new _TerminalConnectToClientParams(); | 953 var params = new _TerminalConnectToClientParams(); |
925 params.terminalClient = terminalClient; | 954 params.terminalClient = terminalClient; |
926 params.force = force; | 955 params.force = force; |
927 return ctrl.sendMessageWithRequestId( | 956 ctrl.sendMessageWithRequestId( |
928 params, | 957 params, |
929 _terminalMethodConnectToClientName, | 958 _terminalMethodConnectToClientName, |
930 -1, | 959 -1, |
931 bindings.MessageHeader.kMessageExpectsResponse); | 960 bindings.MessageHeader.kMessageExpectsResponse, |
| 961 callback); |
932 } | 962 } |
933 dynamic getSize([Function responseFactory = null]) { | 963 void getSize(void callback(types_mojom.Error error, int rows, int columns)) { |
934 if (impl != null) { | 964 if (impl != null) { |
935 return new Future(() => impl.getSize(_TerminalStubControl._terminalGetSize
ResponseParamsFactory)); | 965 impl.getSize(callback); |
| 966 return; |
936 } | 967 } |
937 var params = new _TerminalGetSizeParams(); | 968 var params = new _TerminalGetSizeParams(); |
938 return ctrl.sendMessageWithRequestId( | 969 ctrl.sendMessageWithRequestId( |
939 params, | 970 params, |
940 _terminalMethodGetSizeName, | 971 _terminalMethodGetSizeName, |
941 -1, | 972 -1, |
942 bindings.MessageHeader.kMessageExpectsResponse); | 973 bindings.MessageHeader.kMessageExpectsResponse, |
| 974 callback); |
943 } | 975 } |
944 dynamic setSize(int rows,int columns,bool reset,[Function responseFactory = nu
ll]) { | 976 void setSize(int rows,int columns,bool reset,void callback(types_mojom.Error e
rror, int rows, int columns)) { |
945 if (impl != null) { | 977 if (impl != null) { |
946 return new Future(() => impl.setSize(rows,columns,reset,_TerminalStubContr
ol._terminalSetSizeResponseParamsFactory)); | 978 impl.setSize(rows,columns,reset,callback); |
| 979 return; |
947 } | 980 } |
948 var params = new _TerminalSetSizeParams(); | 981 var params = new _TerminalSetSizeParams(); |
949 params.rows = rows; | 982 params.rows = rows; |
950 params.columns = columns; | 983 params.columns = columns; |
951 params.reset = reset; | 984 params.reset = reset; |
952 return ctrl.sendMessageWithRequestId( | 985 ctrl.sendMessageWithRequestId( |
953 params, | 986 params, |
954 _terminalMethodSetSizeName, | 987 _terminalMethodSetSizeName, |
955 -1, | 988 -1, |
956 bindings.MessageHeader.kMessageExpectsResponse); | 989 bindings.MessageHeader.kMessageExpectsResponse, |
| 990 callback); |
957 } | 991 } |
958 } | 992 } |
959 | 993 |
960 class _TerminalStubControl | 994 class _TerminalStubControl |
961 extends bindings.StubMessageHandler | 995 extends bindings.StubMessageHandler |
962 implements bindings.StubControl<Terminal> { | 996 implements bindings.StubControl<Terminal> { |
963 Terminal _impl; | 997 Terminal _impl; |
964 | 998 |
965 _TerminalStubControl.fromEndpoint( | 999 _TerminalStubControl.fromEndpoint( |
966 core.MojoMessagePipeEndpoint endpoint, [Terminal impl]) | 1000 core.MojoMessagePipeEndpoint endpoint, [Terminal impl]) |
967 : super.fromEndpoint(endpoint, autoBegin: impl != null) { | 1001 : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
968 _impl = impl; | 1002 _impl = impl; |
969 } | 1003 } |
970 | 1004 |
971 _TerminalStubControl.fromHandle( | 1005 _TerminalStubControl.fromHandle( |
972 core.MojoHandle handle, [Terminal impl]) | 1006 core.MojoHandle handle, [Terminal impl]) |
973 : super.fromHandle(handle, autoBegin: impl != null) { | 1007 : super.fromHandle(handle, autoBegin: impl != null) { |
974 _impl = impl; | 1008 _impl = impl; |
975 } | 1009 } |
976 | 1010 |
977 _TerminalStubControl.unbound([this._impl]) : super.unbound(); | 1011 _TerminalStubControl.unbound([this._impl]) : super.unbound(); |
978 | 1012 |
979 String get serviceName => Terminal.serviceName; | 1013 String get serviceName => Terminal.serviceName; |
980 | 1014 |
981 | 1015 |
982 static TerminalConnectResponseParams _terminalConnectResponseParamsFactory(typ
es_mojom.Error error) { | 1016 Function _terminalConnectResponseParamsResponder( |
983 var result = new TerminalConnectResponseParams(); | 1017 int requestId) { |
984 result.error = error; | 1018 return (types_mojom.Error error) { |
985 return result; | 1019 var result = new TerminalConnectResponseParams(); |
| 1020 result.error = error; |
| 1021 sendResponse(buildResponseWithId( |
| 1022 result, |
| 1023 _terminalMethodConnectName, |
| 1024 requestId, |
| 1025 bindings.MessageHeader.kMessageIsResponse)); |
| 1026 }; |
986 } | 1027 } |
987 static TerminalConnectToClientResponseParams _terminalConnectToClientResponseP
aramsFactory(types_mojom.Error error) { | 1028 Function _terminalConnectToClientResponseParamsResponder( |
988 var result = new TerminalConnectToClientResponseParams(); | 1029 int requestId) { |
989 result.error = error; | 1030 return (types_mojom.Error error) { |
990 return result; | 1031 var result = new TerminalConnectToClientResponseParams(); |
| 1032 result.error = error; |
| 1033 sendResponse(buildResponseWithId( |
| 1034 result, |
| 1035 _terminalMethodConnectToClientName, |
| 1036 requestId, |
| 1037 bindings.MessageHeader.kMessageIsResponse)); |
| 1038 }; |
991 } | 1039 } |
992 static TerminalGetSizeResponseParams _terminalGetSizeResponseParamsFactory(typ
es_mojom.Error error, int rows, int columns) { | 1040 Function _terminalGetSizeResponseParamsResponder( |
993 var result = new TerminalGetSizeResponseParams(); | 1041 int requestId) { |
994 result.error = error; | 1042 return (types_mojom.Error error, int rows, int columns) { |
995 result.rows = rows; | 1043 var result = new TerminalGetSizeResponseParams(); |
996 result.columns = columns; | 1044 result.error = error; |
997 return result; | 1045 result.rows = rows; |
| 1046 result.columns = columns; |
| 1047 sendResponse(buildResponseWithId( |
| 1048 result, |
| 1049 _terminalMethodGetSizeName, |
| 1050 requestId, |
| 1051 bindings.MessageHeader.kMessageIsResponse)); |
| 1052 }; |
998 } | 1053 } |
999 static TerminalSetSizeResponseParams _terminalSetSizeResponseParamsFactory(typ
es_mojom.Error error, int rows, int columns) { | 1054 Function _terminalSetSizeResponseParamsResponder( |
1000 var result = new TerminalSetSizeResponseParams(); | 1055 int requestId) { |
1001 result.error = error; | 1056 return (types_mojom.Error error, int rows, int columns) { |
1002 result.rows = rows; | 1057 var result = new TerminalSetSizeResponseParams(); |
1003 result.columns = columns; | 1058 result.error = error; |
1004 return result; | 1059 result.rows = rows; |
| 1060 result.columns = columns; |
| 1061 sendResponse(buildResponseWithId( |
| 1062 result, |
| 1063 _terminalMethodSetSizeName, |
| 1064 requestId, |
| 1065 bindings.MessageHeader.kMessageIsResponse)); |
| 1066 }; |
1005 } | 1067 } |
1006 | 1068 |
1007 dynamic handleMessage(bindings.ServiceMessage message) { | 1069 void handleMessage(bindings.ServiceMessage message) { |
1008 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 1070 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
1009 return bindings.ControlMessageHandler.handleMessage(this, | 1071 bindings.ControlMessageHandler.handleMessage( |
1010 0, | 1072 this, 0, message); |
1011 message); | 1073 return; |
1012 } | 1074 } |
1013 if (_impl == null) { | 1075 if (_impl == null) { |
1014 throw new core.MojoApiError("$this has no implementation set"); | 1076 throw new core.MojoApiError("$this has no implementation set"); |
1015 } | 1077 } |
1016 switch (message.header.type) { | 1078 switch (message.header.type) { |
1017 case _terminalMethodConnectName: | 1079 case _terminalMethodConnectName: |
1018 var params = _TerminalConnectParams.deserialize( | 1080 var params = _TerminalConnectParams.deserialize( |
1019 message.payload); | 1081 message.payload); |
1020 var response = _impl.connect(params.terminalFile,params.force,_terminalC
onnectResponseParamsFactory); | 1082 _impl.connect(params.terminalFile, params.force, _terminalConnectRespons
eParamsResponder(message.header.requestId)); |
1021 if (response is Future) { | |
1022 return response.then((response) { | |
1023 if (response != null) { | |
1024 return buildResponseWithId( | |
1025 response, | |
1026 _terminalMethodConnectName, | |
1027 message.header.requestId, | |
1028 bindings.MessageHeader.kMessageIsResponse); | |
1029 } | |
1030 }); | |
1031 } else if (response != null) { | |
1032 return buildResponseWithId( | |
1033 response, | |
1034 _terminalMethodConnectName, | |
1035 message.header.requestId, | |
1036 bindings.MessageHeader.kMessageIsResponse); | |
1037 } | |
1038 break; | 1083 break; |
1039 case _terminalMethodConnectToClientName: | 1084 case _terminalMethodConnectToClientName: |
1040 var params = _TerminalConnectToClientParams.deserialize( | 1085 var params = _TerminalConnectToClientParams.deserialize( |
1041 message.payload); | 1086 message.payload); |
1042 var response = _impl.connectToClient(params.terminalClient,params.force,
_terminalConnectToClientResponseParamsFactory); | 1087 _impl.connectToClient(params.terminalClient, params.force, _terminalConn
ectToClientResponseParamsResponder(message.header.requestId)); |
1043 if (response is Future) { | |
1044 return response.then((response) { | |
1045 if (response != null) { | |
1046 return buildResponseWithId( | |
1047 response, | |
1048 _terminalMethodConnectToClientName, | |
1049 message.header.requestId, | |
1050 bindings.MessageHeader.kMessageIsResponse); | |
1051 } | |
1052 }); | |
1053 } else if (response != null) { | |
1054 return buildResponseWithId( | |
1055 response, | |
1056 _terminalMethodConnectToClientName, | |
1057 message.header.requestId, | |
1058 bindings.MessageHeader.kMessageIsResponse); | |
1059 } | |
1060 break; | 1088 break; |
1061 case _terminalMethodGetSizeName: | 1089 case _terminalMethodGetSizeName: |
1062 var response = _impl.getSize(_terminalGetSizeResponseParamsFactory); | 1090 _impl.getSize(_terminalGetSizeResponseParamsResponder(message.header.req
uestId)); |
1063 if (response is Future) { | |
1064 return response.then((response) { | |
1065 if (response != null) { | |
1066 return buildResponseWithId( | |
1067 response, | |
1068 _terminalMethodGetSizeName, | |
1069 message.header.requestId, | |
1070 bindings.MessageHeader.kMessageIsResponse); | |
1071 } | |
1072 }); | |
1073 } else if (response != null) { | |
1074 return buildResponseWithId( | |
1075 response, | |
1076 _terminalMethodGetSizeName, | |
1077 message.header.requestId, | |
1078 bindings.MessageHeader.kMessageIsResponse); | |
1079 } | |
1080 break; | 1091 break; |
1081 case _terminalMethodSetSizeName: | 1092 case _terminalMethodSetSizeName: |
1082 var params = _TerminalSetSizeParams.deserialize( | 1093 var params = _TerminalSetSizeParams.deserialize( |
1083 message.payload); | 1094 message.payload); |
1084 var response = _impl.setSize(params.rows,params.columns,params.reset,_te
rminalSetSizeResponseParamsFactory); | 1095 _impl.setSize(params.rows, params.columns, params.reset, _terminalSetSiz
eResponseParamsResponder(message.header.requestId)); |
1085 if (response is Future) { | |
1086 return response.then((response) { | |
1087 if (response != null) { | |
1088 return buildResponseWithId( | |
1089 response, | |
1090 _terminalMethodSetSizeName, | |
1091 message.header.requestId, | |
1092 bindings.MessageHeader.kMessageIsResponse); | |
1093 } | |
1094 }); | |
1095 } else if (response != null) { | |
1096 return buildResponseWithId( | |
1097 response, | |
1098 _terminalMethodSetSizeName, | |
1099 message.header.requestId, | |
1100 bindings.MessageHeader.kMessageIsResponse); | |
1101 } | |
1102 break; | 1096 break; |
1103 default: | 1097 default: |
1104 throw new bindings.MojoCodecError("Unexpected message name"); | 1098 throw new bindings.MojoCodecError("Unexpected message name"); |
1105 break; | 1099 break; |
1106 } | 1100 } |
1107 return null; | |
1108 } | 1101 } |
1109 | 1102 |
1110 Terminal get impl => _impl; | 1103 Terminal get impl => _impl; |
1111 set impl(Terminal d) { | 1104 set impl(Terminal d) { |
1112 if (d == null) { | 1105 if (d == null) { |
1113 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 1106 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
1114 } | 1107 } |
1115 if (isBound && (_impl == null)) { | 1108 if (isBound && (_impl == null)) { |
1116 beginHandlingEvents(); | 1109 beginHandlingEvents(); |
1117 } | 1110 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1151 core.MojoHandle handle, [Terminal impl]) | 1144 core.MojoHandle handle, [Terminal impl]) |
1152 : super(new _TerminalStubControl.fromHandle(handle, impl)); | 1145 : super(new _TerminalStubControl.fromHandle(handle, impl)); |
1153 | 1146 |
1154 static TerminalStub newFromEndpoint( | 1147 static TerminalStub newFromEndpoint( |
1155 core.MojoMessagePipeEndpoint endpoint) { | 1148 core.MojoMessagePipeEndpoint endpoint) { |
1156 assert(endpoint.setDescription("For TerminalStub")); | 1149 assert(endpoint.setDescription("For TerminalStub")); |
1157 return new TerminalStub.fromEndpoint(endpoint); | 1150 return new TerminalStub.fromEndpoint(endpoint); |
1158 } | 1151 } |
1159 | 1152 |
1160 | 1153 |
1161 dynamic connect(file_mojom.FileInterfaceRequest terminalFile,bool force,[Funct
ion responseFactory = null]) { | 1154 void connect(file_mojom.FileInterfaceRequest terminalFile,bool force,void call
back(types_mojom.Error error)) { |
1162 return impl.connect(terminalFile,force,responseFactory); | 1155 return impl.connect(terminalFile,force,callback); |
1163 } | 1156 } |
1164 dynamic connectToClient(terminal_client_mojom.TerminalClientInterface terminal
Client,bool force,[Function responseFactory = null]) { | 1157 void connectToClient(terminal_client_mojom.TerminalClientInterface terminalCli
ent,bool force,void callback(types_mojom.Error error)) { |
1165 return impl.connectToClient(terminalClient,force,responseFactory); | 1158 return impl.connectToClient(terminalClient,force,callback); |
1166 } | 1159 } |
1167 dynamic getSize([Function responseFactory = null]) { | 1160 void getSize(void callback(types_mojom.Error error, int rows, int columns)) { |
1168 return impl.getSize(responseFactory); | 1161 return impl.getSize(callback); |
1169 } | 1162 } |
1170 dynamic setSize(int rows,int columns,bool reset,[Function responseFactory = nu
ll]) { | 1163 void setSize(int rows,int columns,bool reset,void callback(types_mojom.Error e
rror, int rows, int columns)) { |
1171 return impl.setSize(rows,columns,reset,responseFactory); | 1164 return impl.setSize(rows,columns,reset,callback); |
1172 } | 1165 } |
1173 } | 1166 } |
1174 | 1167 |
1175 | 1168 |
1176 | 1169 |
OLD | NEW |