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 network_service_mojom; | 4 library network_service_mojom; |
5 import 'dart:async'; | 5 import 'dart:async'; |
6 import 'package:mojo/bindings.dart' as bindings; | 6 import 'package:mojo/bindings.dart' as bindings; |
7 import 'package:mojo/core.dart' as core; | 7 import 'package:mojo/core.dart' as core; |
8 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; | 8 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; |
9 import 'package:mojo/mojo/network_error.mojom.dart' as network_error_mojom; | 9 import 'package:mojo/mojo/network_error.mojom.dart' as network_error_mojom; |
10 import 'package:mojo_services/mojo/cookie_store.mojom.dart' as cookie_store_mojo
m; | 10 import 'package:mojo_services/mojo/cookie_store.mojom.dart' as cookie_store_mojo
m; |
(...skipping 10 matching lines...) Expand all Loading... |
21 | 21 |
22 | 22 |
23 class _NetworkServiceCreateUrlLoaderParams extends bindings.Struct { | 23 class _NetworkServiceCreateUrlLoaderParams extends bindings.Struct { |
24 static const List<bindings.StructDataHeader> kVersions = const [ | 24 static const List<bindings.StructDataHeader> kVersions = const [ |
25 const bindings.StructDataHeader(16, 0) | 25 const bindings.StructDataHeader(16, 0) |
26 ]; | 26 ]; |
27 url_loader_mojom.UrlLoaderInterfaceRequest loader = null; | 27 url_loader_mojom.UrlLoaderInterfaceRequest loader = null; |
28 | 28 |
29 _NetworkServiceCreateUrlLoaderParams() : super(kVersions.last.size); | 29 _NetworkServiceCreateUrlLoaderParams() : super(kVersions.last.size); |
30 | 30 |
| 31 _NetworkServiceCreateUrlLoaderParams.init( |
| 32 url_loader_mojom.UrlLoaderInterfaceRequest this.loader |
| 33 ) : super(kVersions.last.size); |
| 34 |
31 static _NetworkServiceCreateUrlLoaderParams deserialize(bindings.Message messa
ge) { | 35 static _NetworkServiceCreateUrlLoaderParams deserialize(bindings.Message messa
ge) { |
32 var decoder = new bindings.Decoder(message); | 36 var decoder = new bindings.Decoder(message); |
33 var result = decode(decoder); | 37 var result = decode(decoder); |
34 if (decoder.excessHandles != null) { | 38 if (decoder.excessHandles != null) { |
35 decoder.excessHandles.forEach((h) => h.close()); | 39 decoder.excessHandles.forEach((h) => h.close()); |
36 } | 40 } |
37 return result; | 41 return result; |
38 } | 42 } |
39 | 43 |
40 static _NetworkServiceCreateUrlLoaderParams decode(bindings.Decoder decoder0)
{ | 44 static _NetworkServiceCreateUrlLoaderParams decode(bindings.Decoder decoder0)
{ |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
92 | 96 |
93 | 97 |
94 class _NetworkServiceGetCookieStoreParams extends bindings.Struct { | 98 class _NetworkServiceGetCookieStoreParams extends bindings.Struct { |
95 static const List<bindings.StructDataHeader> kVersions = const [ | 99 static const List<bindings.StructDataHeader> kVersions = const [ |
96 const bindings.StructDataHeader(16, 0) | 100 const bindings.StructDataHeader(16, 0) |
97 ]; | 101 ]; |
98 cookie_store_mojom.CookieStoreInterfaceRequest cookieStore = null; | 102 cookie_store_mojom.CookieStoreInterfaceRequest cookieStore = null; |
99 | 103 |
100 _NetworkServiceGetCookieStoreParams() : super(kVersions.last.size); | 104 _NetworkServiceGetCookieStoreParams() : super(kVersions.last.size); |
101 | 105 |
| 106 _NetworkServiceGetCookieStoreParams.init( |
| 107 cookie_store_mojom.CookieStoreInterfaceRequest this.cookieStore |
| 108 ) : super(kVersions.last.size); |
| 109 |
102 static _NetworkServiceGetCookieStoreParams deserialize(bindings.Message messag
e) { | 110 static _NetworkServiceGetCookieStoreParams deserialize(bindings.Message messag
e) { |
103 var decoder = new bindings.Decoder(message); | 111 var decoder = new bindings.Decoder(message); |
104 var result = decode(decoder); | 112 var result = decode(decoder); |
105 if (decoder.excessHandles != null) { | 113 if (decoder.excessHandles != null) { |
106 decoder.excessHandles.forEach((h) => h.close()); | 114 decoder.excessHandles.forEach((h) => h.close()); |
107 } | 115 } |
108 return result; | 116 return result; |
109 } | 117 } |
110 | 118 |
111 static _NetworkServiceGetCookieStoreParams decode(bindings.Decoder decoder0) { | 119 static _NetworkServiceGetCookieStoreParams decode(bindings.Decoder decoder0) { |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
163 | 171 |
164 | 172 |
165 class _NetworkServiceCreateWebSocketParams extends bindings.Struct { | 173 class _NetworkServiceCreateWebSocketParams extends bindings.Struct { |
166 static const List<bindings.StructDataHeader> kVersions = const [ | 174 static const List<bindings.StructDataHeader> kVersions = const [ |
167 const bindings.StructDataHeader(16, 0) | 175 const bindings.StructDataHeader(16, 0) |
168 ]; | 176 ]; |
169 web_socket_mojom.WebSocketInterfaceRequest socket = null; | 177 web_socket_mojom.WebSocketInterfaceRequest socket = null; |
170 | 178 |
171 _NetworkServiceCreateWebSocketParams() : super(kVersions.last.size); | 179 _NetworkServiceCreateWebSocketParams() : super(kVersions.last.size); |
172 | 180 |
| 181 _NetworkServiceCreateWebSocketParams.init( |
| 182 web_socket_mojom.WebSocketInterfaceRequest this.socket |
| 183 ) : super(kVersions.last.size); |
| 184 |
173 static _NetworkServiceCreateWebSocketParams deserialize(bindings.Message messa
ge) { | 185 static _NetworkServiceCreateWebSocketParams deserialize(bindings.Message messa
ge) { |
174 var decoder = new bindings.Decoder(message); | 186 var decoder = new bindings.Decoder(message); |
175 var result = decode(decoder); | 187 var result = decode(decoder); |
176 if (decoder.excessHandles != null) { | 188 if (decoder.excessHandles != null) { |
177 decoder.excessHandles.forEach((h) => h.close()); | 189 decoder.excessHandles.forEach((h) => h.close()); |
178 } | 190 } |
179 return result; | 191 return result; |
180 } | 192 } |
181 | 193 |
182 static _NetworkServiceCreateWebSocketParams decode(bindings.Decoder decoder0)
{ | 194 static _NetworkServiceCreateWebSocketParams decode(bindings.Decoder decoder0)
{ |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
235 | 247 |
236 class _NetworkServiceCreateTcpBoundSocketParams extends bindings.Struct { | 248 class _NetworkServiceCreateTcpBoundSocketParams extends bindings.Struct { |
237 static const List<bindings.StructDataHeader> kVersions = const [ | 249 static const List<bindings.StructDataHeader> kVersions = const [ |
238 const bindings.StructDataHeader(24, 0) | 250 const bindings.StructDataHeader(24, 0) |
239 ]; | 251 ]; |
240 net_address_mojom.NetAddress localAddress = null; | 252 net_address_mojom.NetAddress localAddress = null; |
241 tcp_bound_socket_mojom.TcpBoundSocketInterfaceRequest boundSocket = null; | 253 tcp_bound_socket_mojom.TcpBoundSocketInterfaceRequest boundSocket = null; |
242 | 254 |
243 _NetworkServiceCreateTcpBoundSocketParams() : super(kVersions.last.size); | 255 _NetworkServiceCreateTcpBoundSocketParams() : super(kVersions.last.size); |
244 | 256 |
| 257 _NetworkServiceCreateTcpBoundSocketParams.init( |
| 258 net_address_mojom.NetAddress this.localAddress, |
| 259 tcp_bound_socket_mojom.TcpBoundSocketInterfaceRequest this.boundSocket |
| 260 ) : super(kVersions.last.size); |
| 261 |
245 static _NetworkServiceCreateTcpBoundSocketParams deserialize(bindings.Message
message) { | 262 static _NetworkServiceCreateTcpBoundSocketParams deserialize(bindings.Message
message) { |
246 var decoder = new bindings.Decoder(message); | 263 var decoder = new bindings.Decoder(message); |
247 var result = decode(decoder); | 264 var result = decode(decoder); |
248 if (decoder.excessHandles != null) { | 265 if (decoder.excessHandles != null) { |
249 decoder.excessHandles.forEach((h) => h.close()); | 266 decoder.excessHandles.forEach((h) => h.close()); |
250 } | 267 } |
251 return result; | 268 return result; |
252 } | 269 } |
253 | 270 |
254 static _NetworkServiceCreateTcpBoundSocketParams decode(bindings.Decoder decod
er0) { | 271 static _NetworkServiceCreateTcpBoundSocketParams decode(bindings.Decoder decod
er0) { |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
320 | 337 |
321 class NetworkServiceCreateTcpBoundSocketResponseParams extends bindings.Struct { | 338 class NetworkServiceCreateTcpBoundSocketResponseParams extends bindings.Struct { |
322 static const List<bindings.StructDataHeader> kVersions = const [ | 339 static const List<bindings.StructDataHeader> kVersions = const [ |
323 const bindings.StructDataHeader(24, 0) | 340 const bindings.StructDataHeader(24, 0) |
324 ]; | 341 ]; |
325 network_error_mojom.NetworkError result = null; | 342 network_error_mojom.NetworkError result = null; |
326 net_address_mojom.NetAddress boundTo = null; | 343 net_address_mojom.NetAddress boundTo = null; |
327 | 344 |
328 NetworkServiceCreateTcpBoundSocketResponseParams() : super(kVersions.last.size
); | 345 NetworkServiceCreateTcpBoundSocketResponseParams() : super(kVersions.last.size
); |
329 | 346 |
| 347 NetworkServiceCreateTcpBoundSocketResponseParams.init( |
| 348 network_error_mojom.NetworkError this.result, |
| 349 net_address_mojom.NetAddress this.boundTo |
| 350 ) : super(kVersions.last.size); |
| 351 |
330 static NetworkServiceCreateTcpBoundSocketResponseParams deserialize(bindings.M
essage message) { | 352 static NetworkServiceCreateTcpBoundSocketResponseParams deserialize(bindings.M
essage message) { |
331 var decoder = new bindings.Decoder(message); | 353 var decoder = new bindings.Decoder(message); |
332 var result = decode(decoder); | 354 var result = decode(decoder); |
333 if (decoder.excessHandles != null) { | 355 if (decoder.excessHandles != null) { |
334 decoder.excessHandles.forEach((h) => h.close()); | 356 decoder.excessHandles.forEach((h) => h.close()); |
335 } | 357 } |
336 return result; | 358 return result; |
337 } | 359 } |
338 | 360 |
339 static NetworkServiceCreateTcpBoundSocketResponseParams decode(bindings.Decode
r decoder0) { | 361 static NetworkServiceCreateTcpBoundSocketResponseParams decode(bindings.Decode
r decoder0) { |
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
410 static const List<bindings.StructDataHeader> kVersions = const [ | 432 static const List<bindings.StructDataHeader> kVersions = const [ |
411 const bindings.StructDataHeader(32, 0) | 433 const bindings.StructDataHeader(32, 0) |
412 ]; | 434 ]; |
413 net_address_mojom.NetAddress remoteAddress = null; | 435 net_address_mojom.NetAddress remoteAddress = null; |
414 core.MojoDataPipeConsumer sendStream = null; | 436 core.MojoDataPipeConsumer sendStream = null; |
415 core.MojoDataPipeProducer receiveStream = null; | 437 core.MojoDataPipeProducer receiveStream = null; |
416 tcp_connected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket = n
ull; | 438 tcp_connected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket = n
ull; |
417 | 439 |
418 _NetworkServiceCreateTcpConnectedSocketParams() : super(kVersions.last.size); | 440 _NetworkServiceCreateTcpConnectedSocketParams() : super(kVersions.last.size); |
419 | 441 |
| 442 _NetworkServiceCreateTcpConnectedSocketParams.init( |
| 443 net_address_mojom.NetAddress this.remoteAddress, |
| 444 core.MojoDataPipeConsumer this.sendStream, |
| 445 core.MojoDataPipeProducer this.receiveStream, |
| 446 tcp_connected_socket_mojom.TcpConnectedSocketInterfaceRequest this.clientSoc
ket |
| 447 ) : super(kVersions.last.size); |
| 448 |
420 static _NetworkServiceCreateTcpConnectedSocketParams deserialize(bindings.Mess
age message) { | 449 static _NetworkServiceCreateTcpConnectedSocketParams deserialize(bindings.Mess
age message) { |
421 var decoder = new bindings.Decoder(message); | 450 var decoder = new bindings.Decoder(message); |
422 var result = decode(decoder); | 451 var result = decode(decoder); |
423 if (decoder.excessHandles != null) { | 452 if (decoder.excessHandles != null) { |
424 decoder.excessHandles.forEach((h) => h.close()); | 453 decoder.excessHandles.forEach((h) => h.close()); |
425 } | 454 } |
426 return result; | 455 return result; |
427 } | 456 } |
428 | 457 |
429 static _NetworkServiceCreateTcpConnectedSocketParams decode(bindings.Decoder d
ecoder0) { | 458 static _NetworkServiceCreateTcpConnectedSocketParams decode(bindings.Decoder d
ecoder0) { |
(...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
519 | 548 |
520 class NetworkServiceCreateTcpConnectedSocketResponseParams extends bindings.Stru
ct { | 549 class NetworkServiceCreateTcpConnectedSocketResponseParams extends bindings.Stru
ct { |
521 static const List<bindings.StructDataHeader> kVersions = const [ | 550 static const List<bindings.StructDataHeader> kVersions = const [ |
522 const bindings.StructDataHeader(24, 0) | 551 const bindings.StructDataHeader(24, 0) |
523 ]; | 552 ]; |
524 network_error_mojom.NetworkError result = null; | 553 network_error_mojom.NetworkError result = null; |
525 net_address_mojom.NetAddress localAddress = null; | 554 net_address_mojom.NetAddress localAddress = null; |
526 | 555 |
527 NetworkServiceCreateTcpConnectedSocketResponseParams() : super(kVersions.last.
size); | 556 NetworkServiceCreateTcpConnectedSocketResponseParams() : super(kVersions.last.
size); |
528 | 557 |
| 558 NetworkServiceCreateTcpConnectedSocketResponseParams.init( |
| 559 network_error_mojom.NetworkError this.result, |
| 560 net_address_mojom.NetAddress this.localAddress |
| 561 ) : super(kVersions.last.size); |
| 562 |
529 static NetworkServiceCreateTcpConnectedSocketResponseParams deserialize(bindin
gs.Message message) { | 563 static NetworkServiceCreateTcpConnectedSocketResponseParams deserialize(bindin
gs.Message message) { |
530 var decoder = new bindings.Decoder(message); | 564 var decoder = new bindings.Decoder(message); |
531 var result = decode(decoder); | 565 var result = decode(decoder); |
532 if (decoder.excessHandles != null) { | 566 if (decoder.excessHandles != null) { |
533 decoder.excessHandles.forEach((h) => h.close()); | 567 decoder.excessHandles.forEach((h) => h.close()); |
534 } | 568 } |
535 return result; | 569 return result; |
536 } | 570 } |
537 | 571 |
538 static NetworkServiceCreateTcpConnectedSocketResponseParams decode(bindings.De
coder decoder0) { | 572 static NetworkServiceCreateTcpConnectedSocketResponseParams decode(bindings.De
coder decoder0) { |
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
606 | 640 |
607 | 641 |
608 class _NetworkServiceCreateUdpSocketParams extends bindings.Struct { | 642 class _NetworkServiceCreateUdpSocketParams extends bindings.Struct { |
609 static const List<bindings.StructDataHeader> kVersions = const [ | 643 static const List<bindings.StructDataHeader> kVersions = const [ |
610 const bindings.StructDataHeader(16, 0) | 644 const bindings.StructDataHeader(16, 0) |
611 ]; | 645 ]; |
612 udp_socket_mojom.UdpSocketInterfaceRequest socket = null; | 646 udp_socket_mojom.UdpSocketInterfaceRequest socket = null; |
613 | 647 |
614 _NetworkServiceCreateUdpSocketParams() : super(kVersions.last.size); | 648 _NetworkServiceCreateUdpSocketParams() : super(kVersions.last.size); |
615 | 649 |
| 650 _NetworkServiceCreateUdpSocketParams.init( |
| 651 udp_socket_mojom.UdpSocketInterfaceRequest this.socket |
| 652 ) : super(kVersions.last.size); |
| 653 |
616 static _NetworkServiceCreateUdpSocketParams deserialize(bindings.Message messa
ge) { | 654 static _NetworkServiceCreateUdpSocketParams deserialize(bindings.Message messa
ge) { |
617 var decoder = new bindings.Decoder(message); | 655 var decoder = new bindings.Decoder(message); |
618 var result = decode(decoder); | 656 var result = decode(decoder); |
619 if (decoder.excessHandles != null) { | 657 if (decoder.excessHandles != null) { |
620 decoder.excessHandles.forEach((h) => h.close()); | 658 decoder.excessHandles.forEach((h) => h.close()); |
621 } | 659 } |
622 return result; | 660 return result; |
623 } | 661 } |
624 | 662 |
625 static _NetworkServiceCreateUdpSocketParams decode(bindings.Decoder decoder0)
{ | 663 static _NetworkServiceCreateUdpSocketParams decode(bindings.Decoder decoder0)
{ |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
678 | 716 |
679 class _NetworkServiceCreateHttpServerParams extends bindings.Struct { | 717 class _NetworkServiceCreateHttpServerParams extends bindings.Struct { |
680 static const List<bindings.StructDataHeader> kVersions = const [ | 718 static const List<bindings.StructDataHeader> kVersions = const [ |
681 const bindings.StructDataHeader(24, 0) | 719 const bindings.StructDataHeader(24, 0) |
682 ]; | 720 ]; |
683 net_address_mojom.NetAddress localAddress = null; | 721 net_address_mojom.NetAddress localAddress = null; |
684 http_server_mojom.HttpServerDelegateInterface delegate = null; | 722 http_server_mojom.HttpServerDelegateInterface delegate = null; |
685 | 723 |
686 _NetworkServiceCreateHttpServerParams() : super(kVersions.last.size); | 724 _NetworkServiceCreateHttpServerParams() : super(kVersions.last.size); |
687 | 725 |
| 726 _NetworkServiceCreateHttpServerParams.init( |
| 727 net_address_mojom.NetAddress this.localAddress, |
| 728 http_server_mojom.HttpServerDelegateInterface this.delegate |
| 729 ) : super(kVersions.last.size); |
| 730 |
688 static _NetworkServiceCreateHttpServerParams deserialize(bindings.Message mess
age) { | 731 static _NetworkServiceCreateHttpServerParams deserialize(bindings.Message mess
age) { |
689 var decoder = new bindings.Decoder(message); | 732 var decoder = new bindings.Decoder(message); |
690 var result = decode(decoder); | 733 var result = decode(decoder); |
691 if (decoder.excessHandles != null) { | 734 if (decoder.excessHandles != null) { |
692 decoder.excessHandles.forEach((h) => h.close()); | 735 decoder.excessHandles.forEach((h) => h.close()); |
693 } | 736 } |
694 return result; | 737 return result; |
695 } | 738 } |
696 | 739 |
697 static _NetworkServiceCreateHttpServerParams decode(bindings.Decoder decoder0)
{ | 740 static _NetworkServiceCreateHttpServerParams decode(bindings.Decoder decoder0)
{ |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
763 | 806 |
764 class NetworkServiceCreateHttpServerResponseParams extends bindings.Struct { | 807 class NetworkServiceCreateHttpServerResponseParams extends bindings.Struct { |
765 static const List<bindings.StructDataHeader> kVersions = const [ | 808 static const List<bindings.StructDataHeader> kVersions = const [ |
766 const bindings.StructDataHeader(24, 0) | 809 const bindings.StructDataHeader(24, 0) |
767 ]; | 810 ]; |
768 network_error_mojom.NetworkError result = null; | 811 network_error_mojom.NetworkError result = null; |
769 net_address_mojom.NetAddress boundTo = null; | 812 net_address_mojom.NetAddress boundTo = null; |
770 | 813 |
771 NetworkServiceCreateHttpServerResponseParams() : super(kVersions.last.size); | 814 NetworkServiceCreateHttpServerResponseParams() : super(kVersions.last.size); |
772 | 815 |
| 816 NetworkServiceCreateHttpServerResponseParams.init( |
| 817 network_error_mojom.NetworkError this.result, |
| 818 net_address_mojom.NetAddress this.boundTo |
| 819 ) : super(kVersions.last.size); |
| 820 |
773 static NetworkServiceCreateHttpServerResponseParams deserialize(bindings.Messa
ge message) { | 821 static NetworkServiceCreateHttpServerResponseParams deserialize(bindings.Messa
ge message) { |
774 var decoder = new bindings.Decoder(message); | 822 var decoder = new bindings.Decoder(message); |
775 var result = decode(decoder); | 823 var result = decode(decoder); |
776 if (decoder.excessHandles != null) { | 824 if (decoder.excessHandles != null) { |
777 decoder.excessHandles.forEach((h) => h.close()); | 825 decoder.excessHandles.forEach((h) => h.close()); |
778 } | 826 } |
779 return result; | 827 return result; |
780 } | 828 } |
781 | 829 |
782 static NetworkServiceCreateHttpServerResponseParams decode(bindings.Decoder de
coder0) { | 830 static NetworkServiceCreateHttpServerResponseParams decode(bindings.Decoder de
coder0) { |
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
850 | 898 |
851 | 899 |
852 class _NetworkServiceRegisterUrlLoaderInterceptorParams extends bindings.Struct
{ | 900 class _NetworkServiceRegisterUrlLoaderInterceptorParams extends bindings.Struct
{ |
853 static const List<bindings.StructDataHeader> kVersions = const [ | 901 static const List<bindings.StructDataHeader> kVersions = const [ |
854 const bindings.StructDataHeader(16, 0) | 902 const bindings.StructDataHeader(16, 0) |
855 ]; | 903 ]; |
856 url_loader_interceptor_mojom.UrlLoaderInterceptorFactoryInterface factory = nu
ll; | 904 url_loader_interceptor_mojom.UrlLoaderInterceptorFactoryInterface factory = nu
ll; |
857 | 905 |
858 _NetworkServiceRegisterUrlLoaderInterceptorParams() : super(kVersions.last.siz
e); | 906 _NetworkServiceRegisterUrlLoaderInterceptorParams() : super(kVersions.last.siz
e); |
859 | 907 |
| 908 _NetworkServiceRegisterUrlLoaderInterceptorParams.init( |
| 909 url_loader_interceptor_mojom.UrlLoaderInterceptorFactoryInterface this.facto
ry |
| 910 ) : super(kVersions.last.size); |
| 911 |
860 static _NetworkServiceRegisterUrlLoaderInterceptorParams deserialize(bindings.
Message message) { | 912 static _NetworkServiceRegisterUrlLoaderInterceptorParams deserialize(bindings.
Message message) { |
861 var decoder = new bindings.Decoder(message); | 913 var decoder = new bindings.Decoder(message); |
862 var result = decode(decoder); | 914 var result = decode(decoder); |
863 if (decoder.excessHandles != null) { | 915 if (decoder.excessHandles != null) { |
864 decoder.excessHandles.forEach((h) => h.close()); | 916 decoder.excessHandles.forEach((h) => h.close()); |
865 } | 917 } |
866 return result; | 918 return result; |
867 } | 919 } |
868 | 920 |
869 static _NetworkServiceRegisterUrlLoaderInterceptorParams decode(bindings.Decod
er decoder0) { | 921 static _NetworkServiceRegisterUrlLoaderInterceptorParams decode(bindings.Decod
er decoder0) { |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
921 | 973 |
922 | 974 |
923 class _NetworkServiceCreateHostResolverParams extends bindings.Struct { | 975 class _NetworkServiceCreateHostResolverParams extends bindings.Struct { |
924 static const List<bindings.StructDataHeader> kVersions = const [ | 976 static const List<bindings.StructDataHeader> kVersions = const [ |
925 const bindings.StructDataHeader(16, 0) | 977 const bindings.StructDataHeader(16, 0) |
926 ]; | 978 ]; |
927 host_resolver_mojom.HostResolverInterfaceRequest hostResolver = null; | 979 host_resolver_mojom.HostResolverInterfaceRequest hostResolver = null; |
928 | 980 |
929 _NetworkServiceCreateHostResolverParams() : super(kVersions.last.size); | 981 _NetworkServiceCreateHostResolverParams() : super(kVersions.last.size); |
930 | 982 |
| 983 _NetworkServiceCreateHostResolverParams.init( |
| 984 host_resolver_mojom.HostResolverInterfaceRequest this.hostResolver |
| 985 ) : super(kVersions.last.size); |
| 986 |
931 static _NetworkServiceCreateHostResolverParams deserialize(bindings.Message me
ssage) { | 987 static _NetworkServiceCreateHostResolverParams deserialize(bindings.Message me
ssage) { |
932 var decoder = new bindings.Decoder(message); | 988 var decoder = new bindings.Decoder(message); |
933 var result = decode(decoder); | 989 var result = decode(decoder); |
934 if (decoder.excessHandles != null) { | 990 if (decoder.excessHandles != null) { |
935 decoder.excessHandles.forEach((h) => h.close()); | 991 decoder.excessHandles.forEach((h) => h.close()); |
936 } | 992 } |
937 return result; | 993 return result; |
938 } | 994 } |
939 | 995 |
940 static _NetworkServiceCreateHostResolverParams decode(bindings.Decoder decoder
0) { | 996 static _NetworkServiceCreateHostResolverParams decode(bindings.Decoder decoder
0) { |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
994 const int _networkServiceMethodGetCookieStoreName = 1; | 1050 const int _networkServiceMethodGetCookieStoreName = 1; |
995 const int _networkServiceMethodCreateWebSocketName = 2; | 1051 const int _networkServiceMethodCreateWebSocketName = 2; |
996 const int _networkServiceMethodCreateTcpBoundSocketName = 3; | 1052 const int _networkServiceMethodCreateTcpBoundSocketName = 3; |
997 const int _networkServiceMethodCreateTcpConnectedSocketName = 4; | 1053 const int _networkServiceMethodCreateTcpConnectedSocketName = 4; |
998 const int _networkServiceMethodCreateUdpSocketName = 5; | 1054 const int _networkServiceMethodCreateUdpSocketName = 5; |
999 const int _networkServiceMethodCreateHttpServerName = 6; | 1055 const int _networkServiceMethodCreateHttpServerName = 6; |
1000 const int _networkServiceMethodRegisterUrlLoaderInterceptorName = 7; | 1056 const int _networkServiceMethodRegisterUrlLoaderInterceptorName = 7; |
1001 const int _networkServiceMethodCreateHostResolverName = 8; | 1057 const int _networkServiceMethodCreateHostResolverName = 8; |
1002 | 1058 |
1003 class _NetworkServiceServiceDescription implements service_describer.ServiceDesc
ription { | 1059 class _NetworkServiceServiceDescription implements service_describer.ServiceDesc
ription { |
1004 dynamic getTopLevelInterface([Function responseFactory]) => | 1060 void getTopLevelInterface(Function responder) { |
1005 responseFactory(null); | 1061 responder(null); |
| 1062 } |
1006 | 1063 |
1007 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 1064 void getTypeDefinition(String typeKey, Function responder) { |
1008 responseFactory(null); | 1065 responder(null); |
| 1066 } |
1009 | 1067 |
1010 dynamic getAllTypeDefinitions([Function responseFactory]) => | 1068 void getAllTypeDefinitions(Function responder) { |
1011 responseFactory(null); | 1069 responder(null); |
| 1070 } |
1012 } | 1071 } |
1013 | 1072 |
1014 abstract class NetworkService { | 1073 abstract class NetworkService { |
1015 static const String serviceName = "mojo::NetworkService"; | 1074 static const String serviceName = "mojo::NetworkService"; |
1016 | 1075 |
1017 static service_describer.ServiceDescription _cachedServiceDescription; | 1076 static service_describer.ServiceDescription _cachedServiceDescription; |
1018 static service_describer.ServiceDescription get serviceDescription { | 1077 static service_describer.ServiceDescription get serviceDescription { |
1019 if (_cachedServiceDescription == null) { | 1078 if (_cachedServiceDescription == null) { |
1020 _cachedServiceDescription = new _NetworkServiceServiceDescription(); | 1079 _cachedServiceDescription = new _NetworkServiceServiceDescription(); |
1021 } | 1080 } |
1022 return _cachedServiceDescription; | 1081 return _cachedServiceDescription; |
1023 } | 1082 } |
1024 | 1083 |
1025 static NetworkServiceProxy connectToService( | 1084 static NetworkServiceProxy connectToService( |
1026 bindings.ServiceConnector s, String url, [String serviceName]) { | 1085 bindings.ServiceConnector s, String url, [String serviceName]) { |
1027 NetworkServiceProxy p = new NetworkServiceProxy.unbound(); | 1086 NetworkServiceProxy p = new NetworkServiceProxy.unbound(); |
1028 String name = serviceName ?? NetworkService.serviceName; | 1087 String name = serviceName ?? NetworkService.serviceName; |
1029 if ((name == null) || name.isEmpty) { | 1088 if ((name == null) || name.isEmpty) { |
1030 throw new core.MojoApiError( | 1089 throw new core.MojoApiError( |
1031 "If an interface has no ServiceName, then one must be provided."); | 1090 "If an interface has no ServiceName, then one must be provided."); |
1032 } | 1091 } |
1033 s.connectToService(url, p, name); | 1092 s.connectToService(url, p, name); |
1034 return p; | 1093 return p; |
1035 } | 1094 } |
1036 void createUrlLoader(url_loader_mojom.UrlLoaderInterfaceRequest loader); | 1095 void createUrlLoader(url_loader_mojom.UrlLoaderInterfaceRequest loader); |
1037 void getCookieStore(cookie_store_mojom.CookieStoreInterfaceRequest cookieStore
); | 1096 void getCookieStore(cookie_store_mojom.CookieStoreInterfaceRequest cookieStore
); |
1038 void createWebSocket(web_socket_mojom.WebSocketInterfaceRequest socket); | 1097 void createWebSocket(web_socket_mojom.WebSocketInterfaceRequest socket); |
1039 dynamic createTcpBoundSocket(net_address_mojom.NetAddress localAddress,tcp_bou
nd_socket_mojom.TcpBoundSocketInterfaceRequest boundSocket,[Function responseFac
tory = null]); | 1098 void createTcpBoundSocket(net_address_mojom.NetAddress localAddress,tcp_bound_
socket_mojom.TcpBoundSocketInterfaceRequest boundSocket,void callback(network_er
ror_mojom.NetworkError result, net_address_mojom.NetAddress boundTo)); |
1040 dynamic createTcpConnectedSocket(net_address_mojom.NetAddress remoteAddress,co
re.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,tcp_c
onnected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket,[Function
responseFactory = null]); | 1099 void createTcpConnectedSocket(net_address_mojom.NetAddress remoteAddress,core.
MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,tcp_conn
ected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket,void callback
(network_error_mojom.NetworkError result, net_address_mojom.NetAddress localAddr
ess)); |
1041 void createUdpSocket(udp_socket_mojom.UdpSocketInterfaceRequest socket); | 1100 void createUdpSocket(udp_socket_mojom.UdpSocketInterfaceRequest socket); |
1042 dynamic createHttpServer(net_address_mojom.NetAddress localAddress,http_server
_mojom.HttpServerDelegateInterface delegate,[Function responseFactory = null]); | 1101 void createHttpServer(net_address_mojom.NetAddress localAddress,http_server_mo
jom.HttpServerDelegateInterface delegate,void callback(network_error_mojom.Netwo
rkError result, net_address_mojom.NetAddress boundTo)); |
1043 void registerUrlLoaderInterceptor(url_loader_interceptor_mojom.UrlLoaderInterc
eptorFactoryInterface factory); | 1102 void registerUrlLoaderInterceptor(url_loader_interceptor_mojom.UrlLoaderInterc
eptorFactoryInterface factory); |
1044 void createHostResolver(host_resolver_mojom.HostResolverInterfaceRequest hostR
esolver); | 1103 void createHostResolver(host_resolver_mojom.HostResolverInterfaceRequest hostR
esolver); |
1045 } | 1104 } |
1046 | 1105 |
1047 abstract class NetworkServiceInterface | 1106 abstract class NetworkServiceInterface |
1048 implements bindings.MojoInterface<NetworkService>, | 1107 implements bindings.MojoInterface<NetworkService>, |
1049 NetworkService { | 1108 NetworkService { |
1050 factory NetworkServiceInterface([NetworkService impl]) => | 1109 factory NetworkServiceInterface([NetworkService impl]) => |
1051 new NetworkServiceStub.unbound(impl); | 1110 new NetworkServiceStub.unbound(impl); |
1052 | 1111 |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1084 | 1143 |
1085 void handleResponse(bindings.ServiceMessage message) { | 1144 void handleResponse(bindings.ServiceMessage message) { |
1086 switch (message.header.type) { | 1145 switch (message.header.type) { |
1087 case _networkServiceMethodCreateTcpBoundSocketName: | 1146 case _networkServiceMethodCreateTcpBoundSocketName: |
1088 var r = NetworkServiceCreateTcpBoundSocketResponseParams.deserialize( | 1147 var r = NetworkServiceCreateTcpBoundSocketResponseParams.deserialize( |
1089 message.payload); | 1148 message.payload); |
1090 if (!message.header.hasRequestId) { | 1149 if (!message.header.hasRequestId) { |
1091 proxyError("Expected a message with a valid request Id."); | 1150 proxyError("Expected a message with a valid request Id."); |
1092 return; | 1151 return; |
1093 } | 1152 } |
1094 Completer c = completerMap[message.header.requestId]; | 1153 Function callback = callbackMap[message.header.requestId]; |
1095 if (c == null) { | 1154 if (callback == null) { |
1096 proxyError( | 1155 proxyError( |
1097 "Message had unknown request Id: ${message.header.requestId}"); | 1156 "Message had unknown request Id: ${message.header.requestId}"); |
1098 return; | 1157 return; |
1099 } | 1158 } |
1100 completerMap.remove(message.header.requestId); | 1159 callbackMap.remove(message.header.requestId); |
1101 if (c.isCompleted) { | 1160 callback(r.result , r.boundTo ); |
1102 proxyError("Response completer already completed"); | |
1103 return; | |
1104 } | |
1105 c.complete(r); | |
1106 break; | 1161 break; |
1107 case _networkServiceMethodCreateTcpConnectedSocketName: | 1162 case _networkServiceMethodCreateTcpConnectedSocketName: |
1108 var r = NetworkServiceCreateTcpConnectedSocketResponseParams.deserialize
( | 1163 var r = NetworkServiceCreateTcpConnectedSocketResponseParams.deserialize
( |
1109 message.payload); | 1164 message.payload); |
1110 if (!message.header.hasRequestId) { | 1165 if (!message.header.hasRequestId) { |
1111 proxyError("Expected a message with a valid request Id."); | 1166 proxyError("Expected a message with a valid request Id."); |
1112 return; | 1167 return; |
1113 } | 1168 } |
1114 Completer c = completerMap[message.header.requestId]; | 1169 Function callback = callbackMap[message.header.requestId]; |
1115 if (c == null) { | 1170 if (callback == null) { |
1116 proxyError( | 1171 proxyError( |
1117 "Message had unknown request Id: ${message.header.requestId}"); | 1172 "Message had unknown request Id: ${message.header.requestId}"); |
1118 return; | 1173 return; |
1119 } | 1174 } |
1120 completerMap.remove(message.header.requestId); | 1175 callbackMap.remove(message.header.requestId); |
1121 if (c.isCompleted) { | 1176 callback(r.result , r.localAddress ); |
1122 proxyError("Response completer already completed"); | |
1123 return; | |
1124 } | |
1125 c.complete(r); | |
1126 break; | 1177 break; |
1127 case _networkServiceMethodCreateHttpServerName: | 1178 case _networkServiceMethodCreateHttpServerName: |
1128 var r = NetworkServiceCreateHttpServerResponseParams.deserialize( | 1179 var r = NetworkServiceCreateHttpServerResponseParams.deserialize( |
1129 message.payload); | 1180 message.payload); |
1130 if (!message.header.hasRequestId) { | 1181 if (!message.header.hasRequestId) { |
1131 proxyError("Expected a message with a valid request Id."); | 1182 proxyError("Expected a message with a valid request Id."); |
1132 return; | 1183 return; |
1133 } | 1184 } |
1134 Completer c = completerMap[message.header.requestId]; | 1185 Function callback = callbackMap[message.header.requestId]; |
1135 if (c == null) { | 1186 if (callback == null) { |
1136 proxyError( | 1187 proxyError( |
1137 "Message had unknown request Id: ${message.header.requestId}"); | 1188 "Message had unknown request Id: ${message.header.requestId}"); |
1138 return; | 1189 return; |
1139 } | 1190 } |
1140 completerMap.remove(message.header.requestId); | 1191 callbackMap.remove(message.header.requestId); |
1141 if (c.isCompleted) { | 1192 callback(r.result , r.boundTo ); |
1142 proxyError("Response completer already completed"); | |
1143 return; | |
1144 } | |
1145 c.complete(r); | |
1146 break; | 1193 break; |
1147 default: | 1194 default: |
1148 proxyError("Unexpected message type: ${message.header.type}"); | 1195 proxyError("Unexpected message type: ${message.header.type}"); |
1149 close(immediate: true); | 1196 close(immediate: true); |
1150 break; | 1197 break; |
1151 } | 1198 } |
1152 } | 1199 } |
1153 | 1200 |
1154 @override | 1201 @override |
1155 String toString() { | 1202 String toString() { |
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1222 } | 1269 } |
1223 if (!ctrl.isBound) { | 1270 if (!ctrl.isBound) { |
1224 ctrl.proxyError("The Proxy is closed."); | 1271 ctrl.proxyError("The Proxy is closed."); |
1225 return; | 1272 return; |
1226 } | 1273 } |
1227 var params = new _NetworkServiceCreateWebSocketParams(); | 1274 var params = new _NetworkServiceCreateWebSocketParams(); |
1228 params.socket = socket; | 1275 params.socket = socket; |
1229 ctrl.sendMessage(params, | 1276 ctrl.sendMessage(params, |
1230 _networkServiceMethodCreateWebSocketName); | 1277 _networkServiceMethodCreateWebSocketName); |
1231 } | 1278 } |
1232 dynamic createTcpBoundSocket(net_address_mojom.NetAddress localAddress,tcp_bou
nd_socket_mojom.TcpBoundSocketInterfaceRequest boundSocket,[Function responseFac
tory = null]) { | 1279 void createTcpBoundSocket(net_address_mojom.NetAddress localAddress,tcp_bound_
socket_mojom.TcpBoundSocketInterfaceRequest boundSocket,void callback(network_er
ror_mojom.NetworkError result, net_address_mojom.NetAddress boundTo)) { |
1233 if (impl != null) { | 1280 if (impl != null) { |
1234 return new Future(() => impl.createTcpBoundSocket(localAddress,boundSocket
,_NetworkServiceStubControl._networkServiceCreateTcpBoundSocketResponseParamsFac
tory)); | 1281 impl.createTcpBoundSocket(localAddress,boundSocket,callback); |
| 1282 return; |
1235 } | 1283 } |
1236 var params = new _NetworkServiceCreateTcpBoundSocketParams(); | 1284 var params = new _NetworkServiceCreateTcpBoundSocketParams(); |
1237 params.localAddress = localAddress; | 1285 params.localAddress = localAddress; |
1238 params.boundSocket = boundSocket; | 1286 params.boundSocket = boundSocket; |
1239 return ctrl.sendMessageWithRequestId( | 1287 ctrl.sendMessageWithRequestId( |
1240 params, | 1288 params, |
1241 _networkServiceMethodCreateTcpBoundSocketName, | 1289 _networkServiceMethodCreateTcpBoundSocketName, |
1242 -1, | 1290 -1, |
1243 bindings.MessageHeader.kMessageExpectsResponse); | 1291 bindings.MessageHeader.kMessageExpectsResponse, |
| 1292 callback); |
1244 } | 1293 } |
1245 dynamic createTcpConnectedSocket(net_address_mojom.NetAddress remoteAddress,co
re.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,tcp_c
onnected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket,[Function
responseFactory = null]) { | 1294 void createTcpConnectedSocket(net_address_mojom.NetAddress remoteAddress,core.
MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,tcp_conn
ected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket,void callback
(network_error_mojom.NetworkError result, net_address_mojom.NetAddress localAddr
ess)) { |
1246 if (impl != null) { | 1295 if (impl != null) { |
1247 return new Future(() => impl.createTcpConnectedSocket(remoteAddress,sendSt
ream,receiveStream,clientSocket,_NetworkServiceStubControl._networkServiceCreate
TcpConnectedSocketResponseParamsFactory)); | 1296 impl.createTcpConnectedSocket(remoteAddress,sendStream,receiveStream,clien
tSocket,callback); |
| 1297 return; |
1248 } | 1298 } |
1249 var params = new _NetworkServiceCreateTcpConnectedSocketParams(); | 1299 var params = new _NetworkServiceCreateTcpConnectedSocketParams(); |
1250 params.remoteAddress = remoteAddress; | 1300 params.remoteAddress = remoteAddress; |
1251 params.sendStream = sendStream; | 1301 params.sendStream = sendStream; |
1252 params.receiveStream = receiveStream; | 1302 params.receiveStream = receiveStream; |
1253 params.clientSocket = clientSocket; | 1303 params.clientSocket = clientSocket; |
1254 return ctrl.sendMessageWithRequestId( | 1304 ctrl.sendMessageWithRequestId( |
1255 params, | 1305 params, |
1256 _networkServiceMethodCreateTcpConnectedSocketName, | 1306 _networkServiceMethodCreateTcpConnectedSocketName, |
1257 -1, | 1307 -1, |
1258 bindings.MessageHeader.kMessageExpectsResponse); | 1308 bindings.MessageHeader.kMessageExpectsResponse, |
| 1309 callback); |
1259 } | 1310 } |
1260 void createUdpSocket(udp_socket_mojom.UdpSocketInterfaceRequest socket) { | 1311 void createUdpSocket(udp_socket_mojom.UdpSocketInterfaceRequest socket) { |
1261 if (impl != null) { | 1312 if (impl != null) { |
1262 impl.createUdpSocket(socket); | 1313 impl.createUdpSocket(socket); |
1263 return; | 1314 return; |
1264 } | 1315 } |
1265 if (!ctrl.isBound) { | 1316 if (!ctrl.isBound) { |
1266 ctrl.proxyError("The Proxy is closed."); | 1317 ctrl.proxyError("The Proxy is closed."); |
1267 return; | 1318 return; |
1268 } | 1319 } |
1269 var params = new _NetworkServiceCreateUdpSocketParams(); | 1320 var params = new _NetworkServiceCreateUdpSocketParams(); |
1270 params.socket = socket; | 1321 params.socket = socket; |
1271 ctrl.sendMessage(params, | 1322 ctrl.sendMessage(params, |
1272 _networkServiceMethodCreateUdpSocketName); | 1323 _networkServiceMethodCreateUdpSocketName); |
1273 } | 1324 } |
1274 dynamic createHttpServer(net_address_mojom.NetAddress localAddress,http_server
_mojom.HttpServerDelegateInterface delegate,[Function responseFactory = null]) { | 1325 void createHttpServer(net_address_mojom.NetAddress localAddress,http_server_mo
jom.HttpServerDelegateInterface delegate,void callback(network_error_mojom.Netwo
rkError result, net_address_mojom.NetAddress boundTo)) { |
1275 if (impl != null) { | 1326 if (impl != null) { |
1276 return new Future(() => impl.createHttpServer(localAddress,delegate,_Netwo
rkServiceStubControl._networkServiceCreateHttpServerResponseParamsFactory)); | 1327 impl.createHttpServer(localAddress,delegate,callback); |
| 1328 return; |
1277 } | 1329 } |
1278 var params = new _NetworkServiceCreateHttpServerParams(); | 1330 var params = new _NetworkServiceCreateHttpServerParams(); |
1279 params.localAddress = localAddress; | 1331 params.localAddress = localAddress; |
1280 params.delegate = delegate; | 1332 params.delegate = delegate; |
1281 return ctrl.sendMessageWithRequestId( | 1333 ctrl.sendMessageWithRequestId( |
1282 params, | 1334 params, |
1283 _networkServiceMethodCreateHttpServerName, | 1335 _networkServiceMethodCreateHttpServerName, |
1284 -1, | 1336 -1, |
1285 bindings.MessageHeader.kMessageExpectsResponse); | 1337 bindings.MessageHeader.kMessageExpectsResponse, |
| 1338 callback); |
1286 } | 1339 } |
1287 void registerUrlLoaderInterceptor(url_loader_interceptor_mojom.UrlLoaderInterc
eptorFactoryInterface factory) { | 1340 void registerUrlLoaderInterceptor(url_loader_interceptor_mojom.UrlLoaderInterc
eptorFactoryInterface factory) { |
1288 if (impl != null) { | 1341 if (impl != null) { |
1289 impl.registerUrlLoaderInterceptor(factory); | 1342 impl.registerUrlLoaderInterceptor(factory); |
1290 return; | 1343 return; |
1291 } | 1344 } |
1292 if (!ctrl.isBound) { | 1345 if (!ctrl.isBound) { |
1293 ctrl.proxyError("The Proxy is closed."); | 1346 ctrl.proxyError("The Proxy is closed."); |
1294 return; | 1347 return; |
1295 } | 1348 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1329 core.MojoHandle handle, [NetworkService impl]) | 1382 core.MojoHandle handle, [NetworkService impl]) |
1330 : super.fromHandle(handle, autoBegin: impl != null) { | 1383 : super.fromHandle(handle, autoBegin: impl != null) { |
1331 _impl = impl; | 1384 _impl = impl; |
1332 } | 1385 } |
1333 | 1386 |
1334 _NetworkServiceStubControl.unbound([this._impl]) : super.unbound(); | 1387 _NetworkServiceStubControl.unbound([this._impl]) : super.unbound(); |
1335 | 1388 |
1336 String get serviceName => NetworkService.serviceName; | 1389 String get serviceName => NetworkService.serviceName; |
1337 | 1390 |
1338 | 1391 |
1339 static NetworkServiceCreateTcpBoundSocketResponseParams _networkServiceCreateT
cpBoundSocketResponseParamsFactory(network_error_mojom.NetworkError result, net_
address_mojom.NetAddress boundTo) { | 1392 Function _networkServiceCreateTcpBoundSocketResponseParamsResponder( |
1340 var result = new NetworkServiceCreateTcpBoundSocketResponseParams(); | 1393 int requestId) { |
1341 result.result = result; | 1394 return (network_error_mojom.NetworkError result, net_address_mojom.NetAddress
boundTo) { |
1342 result.boundTo = boundTo; | 1395 var result = new NetworkServiceCreateTcpBoundSocketResponseParams(); |
1343 return result; | 1396 result.result = result; |
| 1397 result.boundTo = boundTo; |
| 1398 sendResponse(buildResponseWithId( |
| 1399 result, |
| 1400 _networkServiceMethodCreateTcpBoundSocketName, |
| 1401 requestId, |
| 1402 bindings.MessageHeader.kMessageIsResponse)); |
| 1403 }; |
1344 } | 1404 } |
1345 static NetworkServiceCreateTcpConnectedSocketResponseParams _networkServiceCre
ateTcpConnectedSocketResponseParamsFactory(network_error_mojom.NetworkError resu
lt, net_address_mojom.NetAddress localAddress) { | 1405 Function _networkServiceCreateTcpConnectedSocketResponseParamsResponder( |
1346 var result = new NetworkServiceCreateTcpConnectedSocketResponseParams(); | 1406 int requestId) { |
1347 result.result = result; | 1407 return (network_error_mojom.NetworkError result, net_address_mojom.NetAddress
localAddress) { |
1348 result.localAddress = localAddress; | 1408 var result = new NetworkServiceCreateTcpConnectedSocketResponseParams(); |
1349 return result; | 1409 result.result = result; |
| 1410 result.localAddress = localAddress; |
| 1411 sendResponse(buildResponseWithId( |
| 1412 result, |
| 1413 _networkServiceMethodCreateTcpConnectedSocketName, |
| 1414 requestId, |
| 1415 bindings.MessageHeader.kMessageIsResponse)); |
| 1416 }; |
1350 } | 1417 } |
1351 static NetworkServiceCreateHttpServerResponseParams _networkServiceCreateHttpS
erverResponseParamsFactory(network_error_mojom.NetworkError result, net_address_
mojom.NetAddress boundTo) { | 1418 Function _networkServiceCreateHttpServerResponseParamsResponder( |
1352 var result = new NetworkServiceCreateHttpServerResponseParams(); | 1419 int requestId) { |
1353 result.result = result; | 1420 return (network_error_mojom.NetworkError result, net_address_mojom.NetAddress
boundTo) { |
1354 result.boundTo = boundTo; | 1421 var result = new NetworkServiceCreateHttpServerResponseParams(); |
1355 return result; | 1422 result.result = result; |
| 1423 result.boundTo = boundTo; |
| 1424 sendResponse(buildResponseWithId( |
| 1425 result, |
| 1426 _networkServiceMethodCreateHttpServerName, |
| 1427 requestId, |
| 1428 bindings.MessageHeader.kMessageIsResponse)); |
| 1429 }; |
1356 } | 1430 } |
1357 | 1431 |
1358 dynamic handleMessage(bindings.ServiceMessage message) { | 1432 void handleMessage(bindings.ServiceMessage message) { |
1359 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 1433 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
1360 return bindings.ControlMessageHandler.handleMessage(this, | 1434 bindings.ControlMessageHandler.handleMessage( |
1361 0, | 1435 this, 0, message); |
1362 message); | 1436 return; |
1363 } | 1437 } |
1364 if (_impl == null) { | 1438 if (_impl == null) { |
1365 throw new core.MojoApiError("$this has no implementation set"); | 1439 throw new core.MojoApiError("$this has no implementation set"); |
1366 } | 1440 } |
1367 switch (message.header.type) { | 1441 switch (message.header.type) { |
1368 case _networkServiceMethodCreateUrlLoaderName: | 1442 case _networkServiceMethodCreateUrlLoaderName: |
1369 var params = _NetworkServiceCreateUrlLoaderParams.deserialize( | 1443 var params = _NetworkServiceCreateUrlLoaderParams.deserialize( |
1370 message.payload); | 1444 message.payload); |
1371 _impl.createUrlLoader(params.loader); | 1445 _impl.createUrlLoader(params.loader); |
1372 break; | 1446 break; |
1373 case _networkServiceMethodGetCookieStoreName: | 1447 case _networkServiceMethodGetCookieStoreName: |
1374 var params = _NetworkServiceGetCookieStoreParams.deserialize( | 1448 var params = _NetworkServiceGetCookieStoreParams.deserialize( |
1375 message.payload); | 1449 message.payload); |
1376 _impl.getCookieStore(params.cookieStore); | 1450 _impl.getCookieStore(params.cookieStore); |
1377 break; | 1451 break; |
1378 case _networkServiceMethodCreateWebSocketName: | 1452 case _networkServiceMethodCreateWebSocketName: |
1379 var params = _NetworkServiceCreateWebSocketParams.deserialize( | 1453 var params = _NetworkServiceCreateWebSocketParams.deserialize( |
1380 message.payload); | 1454 message.payload); |
1381 _impl.createWebSocket(params.socket); | 1455 _impl.createWebSocket(params.socket); |
1382 break; | 1456 break; |
1383 case _networkServiceMethodCreateTcpBoundSocketName: | 1457 case _networkServiceMethodCreateTcpBoundSocketName: |
1384 var params = _NetworkServiceCreateTcpBoundSocketParams.deserialize( | 1458 var params = _NetworkServiceCreateTcpBoundSocketParams.deserialize( |
1385 message.payload); | 1459 message.payload); |
1386 var response = _impl.createTcpBoundSocket(params.localAddress,params.bou
ndSocket,_networkServiceCreateTcpBoundSocketResponseParamsFactory); | 1460 _impl.createTcpBoundSocket(params.localAddress, params.boundSocket, _net
workServiceCreateTcpBoundSocketResponseParamsResponder(message.header.requestId)
); |
1387 if (response is Future) { | |
1388 return response.then((response) { | |
1389 if (response != null) { | |
1390 return buildResponseWithId( | |
1391 response, | |
1392 _networkServiceMethodCreateTcpBoundSocketName, | |
1393 message.header.requestId, | |
1394 bindings.MessageHeader.kMessageIsResponse); | |
1395 } | |
1396 }); | |
1397 } else if (response != null) { | |
1398 return buildResponseWithId( | |
1399 response, | |
1400 _networkServiceMethodCreateTcpBoundSocketName, | |
1401 message.header.requestId, | |
1402 bindings.MessageHeader.kMessageIsResponse); | |
1403 } | |
1404 break; | 1461 break; |
1405 case _networkServiceMethodCreateTcpConnectedSocketName: | 1462 case _networkServiceMethodCreateTcpConnectedSocketName: |
1406 var params = _NetworkServiceCreateTcpConnectedSocketParams.deserialize( | 1463 var params = _NetworkServiceCreateTcpConnectedSocketParams.deserialize( |
1407 message.payload); | 1464 message.payload); |
1408 var response = _impl.createTcpConnectedSocket(params.remoteAddress,param
s.sendStream,params.receiveStream,params.clientSocket,_networkServiceCreateTcpCo
nnectedSocketResponseParamsFactory); | 1465 _impl.createTcpConnectedSocket(params.remoteAddress, params.sendStream,
params.receiveStream, params.clientSocket, _networkServiceCreateTcpConnectedSock
etResponseParamsResponder(message.header.requestId)); |
1409 if (response is Future) { | |
1410 return response.then((response) { | |
1411 if (response != null) { | |
1412 return buildResponseWithId( | |
1413 response, | |
1414 _networkServiceMethodCreateTcpConnectedSocketName, | |
1415 message.header.requestId, | |
1416 bindings.MessageHeader.kMessageIsResponse); | |
1417 } | |
1418 }); | |
1419 } else if (response != null) { | |
1420 return buildResponseWithId( | |
1421 response, | |
1422 _networkServiceMethodCreateTcpConnectedSocketName, | |
1423 message.header.requestId, | |
1424 bindings.MessageHeader.kMessageIsResponse); | |
1425 } | |
1426 break; | 1466 break; |
1427 case _networkServiceMethodCreateUdpSocketName: | 1467 case _networkServiceMethodCreateUdpSocketName: |
1428 var params = _NetworkServiceCreateUdpSocketParams.deserialize( | 1468 var params = _NetworkServiceCreateUdpSocketParams.deserialize( |
1429 message.payload); | 1469 message.payload); |
1430 _impl.createUdpSocket(params.socket); | 1470 _impl.createUdpSocket(params.socket); |
1431 break; | 1471 break; |
1432 case _networkServiceMethodCreateHttpServerName: | 1472 case _networkServiceMethodCreateHttpServerName: |
1433 var params = _NetworkServiceCreateHttpServerParams.deserialize( | 1473 var params = _NetworkServiceCreateHttpServerParams.deserialize( |
1434 message.payload); | 1474 message.payload); |
1435 var response = _impl.createHttpServer(params.localAddress,params.delegat
e,_networkServiceCreateHttpServerResponseParamsFactory); | 1475 _impl.createHttpServer(params.localAddress, params.delegate, _networkSer
viceCreateHttpServerResponseParamsResponder(message.header.requestId)); |
1436 if (response is Future) { | |
1437 return response.then((response) { | |
1438 if (response != null) { | |
1439 return buildResponseWithId( | |
1440 response, | |
1441 _networkServiceMethodCreateHttpServerName, | |
1442 message.header.requestId, | |
1443 bindings.MessageHeader.kMessageIsResponse); | |
1444 } | |
1445 }); | |
1446 } else if (response != null) { | |
1447 return buildResponseWithId( | |
1448 response, | |
1449 _networkServiceMethodCreateHttpServerName, | |
1450 message.header.requestId, | |
1451 bindings.MessageHeader.kMessageIsResponse); | |
1452 } | |
1453 break; | 1476 break; |
1454 case _networkServiceMethodRegisterUrlLoaderInterceptorName: | 1477 case _networkServiceMethodRegisterUrlLoaderInterceptorName: |
1455 var params = _NetworkServiceRegisterUrlLoaderInterceptorParams.deseriali
ze( | 1478 var params = _NetworkServiceRegisterUrlLoaderInterceptorParams.deseriali
ze( |
1456 message.payload); | 1479 message.payload); |
1457 _impl.registerUrlLoaderInterceptor(params.factory); | 1480 _impl.registerUrlLoaderInterceptor(params.factory); |
1458 break; | 1481 break; |
1459 case _networkServiceMethodCreateHostResolverName: | 1482 case _networkServiceMethodCreateHostResolverName: |
1460 var params = _NetworkServiceCreateHostResolverParams.deserialize( | 1483 var params = _NetworkServiceCreateHostResolverParams.deserialize( |
1461 message.payload); | 1484 message.payload); |
1462 _impl.createHostResolver(params.hostResolver); | 1485 _impl.createHostResolver(params.hostResolver); |
1463 break; | 1486 break; |
1464 default: | 1487 default: |
1465 throw new bindings.MojoCodecError("Unexpected message name"); | 1488 throw new bindings.MojoCodecError("Unexpected message name"); |
1466 break; | 1489 break; |
1467 } | 1490 } |
1468 return null; | |
1469 } | 1491 } |
1470 | 1492 |
1471 NetworkService get impl => _impl; | 1493 NetworkService get impl => _impl; |
1472 set impl(NetworkService d) { | 1494 set impl(NetworkService d) { |
1473 if (d == null) { | 1495 if (d == null) { |
1474 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 1496 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
1475 } | 1497 } |
1476 if (isBound && (_impl == null)) { | 1498 if (isBound && (_impl == null)) { |
1477 beginHandlingEvents(); | 1499 beginHandlingEvents(); |
1478 } | 1500 } |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1521 | 1543 |
1522 void createUrlLoader(url_loader_mojom.UrlLoaderInterfaceRequest loader) { | 1544 void createUrlLoader(url_loader_mojom.UrlLoaderInterfaceRequest loader) { |
1523 return impl.createUrlLoader(loader); | 1545 return impl.createUrlLoader(loader); |
1524 } | 1546 } |
1525 void getCookieStore(cookie_store_mojom.CookieStoreInterfaceRequest cookieStore
) { | 1547 void getCookieStore(cookie_store_mojom.CookieStoreInterfaceRequest cookieStore
) { |
1526 return impl.getCookieStore(cookieStore); | 1548 return impl.getCookieStore(cookieStore); |
1527 } | 1549 } |
1528 void createWebSocket(web_socket_mojom.WebSocketInterfaceRequest socket) { | 1550 void createWebSocket(web_socket_mojom.WebSocketInterfaceRequest socket) { |
1529 return impl.createWebSocket(socket); | 1551 return impl.createWebSocket(socket); |
1530 } | 1552 } |
1531 dynamic createTcpBoundSocket(net_address_mojom.NetAddress localAddress,tcp_bou
nd_socket_mojom.TcpBoundSocketInterfaceRequest boundSocket,[Function responseFac
tory = null]) { | 1553 void createTcpBoundSocket(net_address_mojom.NetAddress localAddress,tcp_bound_
socket_mojom.TcpBoundSocketInterfaceRequest boundSocket,void callback(network_er
ror_mojom.NetworkError result, net_address_mojom.NetAddress boundTo)) { |
1532 return impl.createTcpBoundSocket(localAddress,boundSocket,responseFactory); | 1554 return impl.createTcpBoundSocket(localAddress,boundSocket,callback); |
1533 } | 1555 } |
1534 dynamic createTcpConnectedSocket(net_address_mojom.NetAddress remoteAddress,co
re.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,tcp_c
onnected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket,[Function
responseFactory = null]) { | 1556 void createTcpConnectedSocket(net_address_mojom.NetAddress remoteAddress,core.
MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,tcp_conn
ected_socket_mojom.TcpConnectedSocketInterfaceRequest clientSocket,void callback
(network_error_mojom.NetworkError result, net_address_mojom.NetAddress localAddr
ess)) { |
1535 return impl.createTcpConnectedSocket(remoteAddress,sendStream,receiveStream,
clientSocket,responseFactory); | 1557 return impl.createTcpConnectedSocket(remoteAddress,sendStream,receiveStream,
clientSocket,callback); |
1536 } | 1558 } |
1537 void createUdpSocket(udp_socket_mojom.UdpSocketInterfaceRequest socket) { | 1559 void createUdpSocket(udp_socket_mojom.UdpSocketInterfaceRequest socket) { |
1538 return impl.createUdpSocket(socket); | 1560 return impl.createUdpSocket(socket); |
1539 } | 1561 } |
1540 dynamic createHttpServer(net_address_mojom.NetAddress localAddress,http_server
_mojom.HttpServerDelegateInterface delegate,[Function responseFactory = null]) { | 1562 void createHttpServer(net_address_mojom.NetAddress localAddress,http_server_mo
jom.HttpServerDelegateInterface delegate,void callback(network_error_mojom.Netwo
rkError result, net_address_mojom.NetAddress boundTo)) { |
1541 return impl.createHttpServer(localAddress,delegate,responseFactory); | 1563 return impl.createHttpServer(localAddress,delegate,callback); |
1542 } | 1564 } |
1543 void registerUrlLoaderInterceptor(url_loader_interceptor_mojom.UrlLoaderInterc
eptorFactoryInterface factory) { | 1565 void registerUrlLoaderInterceptor(url_loader_interceptor_mojom.UrlLoaderInterc
eptorFactoryInterface factory) { |
1544 return impl.registerUrlLoaderInterceptor(factory); | 1566 return impl.registerUrlLoaderInterceptor(factory); |
1545 } | 1567 } |
1546 void createHostResolver(host_resolver_mojom.HostResolverInterfaceRequest hostR
esolver) { | 1568 void createHostResolver(host_resolver_mojom.HostResolverInterfaceRequest hostR
esolver) { |
1547 return impl.createHostResolver(hostResolver); | 1569 return impl.createHostResolver(hostResolver); |
1548 } | 1570 } |
1549 } | 1571 } |
1550 | 1572 |
1551 | 1573 |
1552 | 1574 |
OLD | NEW |