| 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 |