OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 library tracing_mojom; | 5 library tracing_mojom; |
6 import 'dart:async'; | 6 import 'dart:async'; |
7 import 'package:mojo/bindings.dart' as bindings; | 7 import 'package:mojo/bindings.dart' as bindings; |
8 import 'package:mojo/core.dart' as core; | 8 import 'package:mojo/core.dart' as core; |
9 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; | 9 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; |
10 | 10 |
11 | 11 |
12 | 12 |
13 class _TraceProviderStartTracingParams extends bindings.Struct { | 13 class _TraceProviderStartTracingParams extends bindings.Struct { |
14 static const List<bindings.StructDataHeader> kVersions = const [ | 14 static const List<bindings.StructDataHeader> kVersions = const [ |
15 const bindings.StructDataHeader(24, 0) | 15 const bindings.StructDataHeader(24, 0) |
16 ]; | 16 ]; |
17 String categories = null; | 17 String categories = null; |
18 TraceRecorderInterface recorder = null; | 18 TraceRecorderInterface recorder = null; |
19 | 19 |
20 _TraceProviderStartTracingParams() : super(kVersions.last.size); | 20 _TraceProviderStartTracingParams() : super(kVersions.last.size); |
21 | 21 |
| 22 _TraceProviderStartTracingParams.init( |
| 23 String this.categories, |
| 24 TraceRecorderInterface this.recorder |
| 25 ) : super(kVersions.last.size); |
| 26 |
22 static _TraceProviderStartTracingParams deserialize(bindings.Message message)
{ | 27 static _TraceProviderStartTracingParams deserialize(bindings.Message message)
{ |
23 var decoder = new bindings.Decoder(message); | 28 var decoder = new bindings.Decoder(message); |
24 var result = decode(decoder); | 29 var result = decode(decoder); |
25 if (decoder.excessHandles != null) { | 30 if (decoder.excessHandles != null) { |
26 decoder.excessHandles.forEach((h) => h.close()); | 31 decoder.excessHandles.forEach((h) => h.close()); |
27 } | 32 } |
28 return result; | 33 return result; |
29 } | 34 } |
30 | 35 |
31 static _TraceProviderStartTracingParams decode(bindings.Decoder decoder0) { | 36 static _TraceProviderStartTracingParams decode(bindings.Decoder decoder0) { |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
94 } | 99 } |
95 | 100 |
96 | 101 |
97 class _TraceProviderStopTracingParams extends bindings.Struct { | 102 class _TraceProviderStopTracingParams extends bindings.Struct { |
98 static const List<bindings.StructDataHeader> kVersions = const [ | 103 static const List<bindings.StructDataHeader> kVersions = const [ |
99 const bindings.StructDataHeader(8, 0) | 104 const bindings.StructDataHeader(8, 0) |
100 ]; | 105 ]; |
101 | 106 |
102 _TraceProviderStopTracingParams() : super(kVersions.last.size); | 107 _TraceProviderStopTracingParams() : super(kVersions.last.size); |
103 | 108 |
| 109 _TraceProviderStopTracingParams.init( |
| 110 ) : super(kVersions.last.size); |
| 111 |
104 static _TraceProviderStopTracingParams deserialize(bindings.Message message) { | 112 static _TraceProviderStopTracingParams deserialize(bindings.Message message) { |
105 var decoder = new bindings.Decoder(message); | 113 var decoder = new bindings.Decoder(message); |
106 var result = decode(decoder); | 114 var result = decode(decoder); |
107 if (decoder.excessHandles != null) { | 115 if (decoder.excessHandles != null) { |
108 decoder.excessHandles.forEach((h) => h.close()); | 116 decoder.excessHandles.forEach((h) => h.close()); |
109 } | 117 } |
110 return result; | 118 return result; |
111 } | 119 } |
112 | 120 |
113 static _TraceProviderStopTracingParams decode(bindings.Decoder decoder0) { | 121 static _TraceProviderStopTracingParams decode(bindings.Decoder decoder0) { |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
153 | 161 |
154 | 162 |
155 class _TraceRecorderRecordParams extends bindings.Struct { | 163 class _TraceRecorderRecordParams extends bindings.Struct { |
156 static const List<bindings.StructDataHeader> kVersions = const [ | 164 static const List<bindings.StructDataHeader> kVersions = const [ |
157 const bindings.StructDataHeader(16, 0) | 165 const bindings.StructDataHeader(16, 0) |
158 ]; | 166 ]; |
159 String json = null; | 167 String json = null; |
160 | 168 |
161 _TraceRecorderRecordParams() : super(kVersions.last.size); | 169 _TraceRecorderRecordParams() : super(kVersions.last.size); |
162 | 170 |
| 171 _TraceRecorderRecordParams.init( |
| 172 String this.json |
| 173 ) : super(kVersions.last.size); |
| 174 |
163 static _TraceRecorderRecordParams deserialize(bindings.Message message) { | 175 static _TraceRecorderRecordParams deserialize(bindings.Message message) { |
164 var decoder = new bindings.Decoder(message); | 176 var decoder = new bindings.Decoder(message); |
165 var result = decode(decoder); | 177 var result = decode(decoder); |
166 if (decoder.excessHandles != null) { | 178 if (decoder.excessHandles != null) { |
167 decoder.excessHandles.forEach((h) => h.close()); | 179 decoder.excessHandles.forEach((h) => h.close()); |
168 } | 180 } |
169 return result; | 181 return result; |
170 } | 182 } |
171 | 183 |
172 static _TraceRecorderRecordParams decode(bindings.Decoder decoder0) { | 184 static _TraceRecorderRecordParams decode(bindings.Decoder decoder0) { |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
226 | 238 |
227 class _TraceCollectorStartParams extends bindings.Struct { | 239 class _TraceCollectorStartParams extends bindings.Struct { |
228 static const List<bindings.StructDataHeader> kVersions = const [ | 240 static const List<bindings.StructDataHeader> kVersions = const [ |
229 const bindings.StructDataHeader(24, 0) | 241 const bindings.StructDataHeader(24, 0) |
230 ]; | 242 ]; |
231 core.MojoDataPipeProducer stream = null; | 243 core.MojoDataPipeProducer stream = null; |
232 String categories = null; | 244 String categories = null; |
233 | 245 |
234 _TraceCollectorStartParams() : super(kVersions.last.size); | 246 _TraceCollectorStartParams() : super(kVersions.last.size); |
235 | 247 |
| 248 _TraceCollectorStartParams.init( |
| 249 core.MojoDataPipeProducer this.stream, |
| 250 String this.categories |
| 251 ) : super(kVersions.last.size); |
| 252 |
236 static _TraceCollectorStartParams deserialize(bindings.Message message) { | 253 static _TraceCollectorStartParams deserialize(bindings.Message message) { |
237 var decoder = new bindings.Decoder(message); | 254 var decoder = new bindings.Decoder(message); |
238 var result = decode(decoder); | 255 var result = decode(decoder); |
239 if (decoder.excessHandles != null) { | 256 if (decoder.excessHandles != null) { |
240 decoder.excessHandles.forEach((h) => h.close()); | 257 decoder.excessHandles.forEach((h) => h.close()); |
241 } | 258 } |
242 return result; | 259 return result; |
243 } | 260 } |
244 | 261 |
245 static _TraceCollectorStartParams decode(bindings.Decoder decoder0) { | 262 static _TraceCollectorStartParams decode(bindings.Decoder decoder0) { |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
308 } | 325 } |
309 | 326 |
310 | 327 |
311 class _TraceCollectorStopAndFlushParams extends bindings.Struct { | 328 class _TraceCollectorStopAndFlushParams extends bindings.Struct { |
312 static const List<bindings.StructDataHeader> kVersions = const [ | 329 static const List<bindings.StructDataHeader> kVersions = const [ |
313 const bindings.StructDataHeader(8, 0) | 330 const bindings.StructDataHeader(8, 0) |
314 ]; | 331 ]; |
315 | 332 |
316 _TraceCollectorStopAndFlushParams() : super(kVersions.last.size); | 333 _TraceCollectorStopAndFlushParams() : super(kVersions.last.size); |
317 | 334 |
| 335 _TraceCollectorStopAndFlushParams.init( |
| 336 ) : super(kVersions.last.size); |
| 337 |
318 static _TraceCollectorStopAndFlushParams deserialize(bindings.Message message)
{ | 338 static _TraceCollectorStopAndFlushParams deserialize(bindings.Message message)
{ |
319 var decoder = new bindings.Decoder(message); | 339 var decoder = new bindings.Decoder(message); |
320 var result = decode(decoder); | 340 var result = decode(decoder); |
321 if (decoder.excessHandles != null) { | 341 if (decoder.excessHandles != null) { |
322 decoder.excessHandles.forEach((h) => h.close()); | 342 decoder.excessHandles.forEach((h) => h.close()); |
323 } | 343 } |
324 return result; | 344 return result; |
325 } | 345 } |
326 | 346 |
327 static _TraceCollectorStopAndFlushParams decode(bindings.Decoder decoder0) { | 347 static _TraceCollectorStopAndFlushParams decode(bindings.Decoder decoder0) { |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
362 Map toJson() { | 382 Map toJson() { |
363 Map map = new Map(); | 383 Map map = new Map(); |
364 return map; | 384 return map; |
365 } | 385 } |
366 } | 386 } |
367 | 387 |
368 const int _traceProviderMethodStartTracingName = 0; | 388 const int _traceProviderMethodStartTracingName = 0; |
369 const int _traceProviderMethodStopTracingName = 1; | 389 const int _traceProviderMethodStopTracingName = 1; |
370 | 390 |
371 class _TraceProviderServiceDescription implements service_describer.ServiceDescr
iption { | 391 class _TraceProviderServiceDescription implements service_describer.ServiceDescr
iption { |
372 dynamic getTopLevelInterface([Function responseFactory]) => | 392 void getTopLevelInterface(Function responder) { |
373 responseFactory(null); | 393 responder(null); |
| 394 } |
374 | 395 |
375 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 396 void getTypeDefinition(String typeKey, Function responder) { |
376 responseFactory(null); | 397 responder(null); |
| 398 } |
377 | 399 |
378 dynamic getAllTypeDefinitions([Function responseFactory]) => | 400 void getAllTypeDefinitions(Function responder) { |
379 responseFactory(null); | 401 responder(null); |
| 402 } |
380 } | 403 } |
381 | 404 |
382 abstract class TraceProvider { | 405 abstract class TraceProvider { |
383 static const String serviceName = "tracing::TraceProvider"; | 406 static const String serviceName = "tracing::TraceProvider"; |
384 | 407 |
385 static service_describer.ServiceDescription _cachedServiceDescription; | 408 static service_describer.ServiceDescription _cachedServiceDescription; |
386 static service_describer.ServiceDescription get serviceDescription { | 409 static service_describer.ServiceDescription get serviceDescription { |
387 if (_cachedServiceDescription == null) { | 410 if (_cachedServiceDescription == null) { |
388 _cachedServiceDescription = new _TraceProviderServiceDescription(); | 411 _cachedServiceDescription = new _TraceProviderServiceDescription(); |
389 } | 412 } |
(...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
517 : super.fromHandle(handle, autoBegin: impl != null) { | 540 : super.fromHandle(handle, autoBegin: impl != null) { |
518 _impl = impl; | 541 _impl = impl; |
519 } | 542 } |
520 | 543 |
521 _TraceProviderStubControl.unbound([this._impl]) : super.unbound(); | 544 _TraceProviderStubControl.unbound([this._impl]) : super.unbound(); |
522 | 545 |
523 String get serviceName => TraceProvider.serviceName; | 546 String get serviceName => TraceProvider.serviceName; |
524 | 547 |
525 | 548 |
526 | 549 |
527 dynamic handleMessage(bindings.ServiceMessage message) { | 550 void handleMessage(bindings.ServiceMessage message) { |
528 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 551 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
529 return bindings.ControlMessageHandler.handleMessage(this, | 552 bindings.ControlMessageHandler.handleMessage( |
530 0, | 553 this, 0, message); |
531 message); | 554 return; |
532 } | 555 } |
533 if (_impl == null) { | 556 if (_impl == null) { |
534 throw new core.MojoApiError("$this has no implementation set"); | 557 throw new core.MojoApiError("$this has no implementation set"); |
535 } | 558 } |
536 switch (message.header.type) { | 559 switch (message.header.type) { |
537 case _traceProviderMethodStartTracingName: | 560 case _traceProviderMethodStartTracingName: |
538 var params = _TraceProviderStartTracingParams.deserialize( | 561 var params = _TraceProviderStartTracingParams.deserialize( |
539 message.payload); | 562 message.payload); |
540 _impl.startTracing(params.categories, params.recorder); | 563 _impl.startTracing(params.categories, params.recorder); |
541 break; | 564 break; |
542 case _traceProviderMethodStopTracingName: | 565 case _traceProviderMethodStopTracingName: |
543 _impl.stopTracing(); | 566 _impl.stopTracing(); |
544 break; | 567 break; |
545 default: | 568 default: |
546 throw new bindings.MojoCodecError("Unexpected message name"); | 569 throw new bindings.MojoCodecError("Unexpected message name"); |
547 break; | 570 break; |
548 } | 571 } |
549 return null; | |
550 } | 572 } |
551 | 573 |
552 TraceProvider get impl => _impl; | 574 TraceProvider get impl => _impl; |
553 set impl(TraceProvider d) { | 575 set impl(TraceProvider d) { |
554 if (d == null) { | 576 if (d == null) { |
555 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 577 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
556 } | 578 } |
557 if (isBound && (_impl == null)) { | 579 if (isBound && (_impl == null)) { |
558 beginHandlingEvents(); | 580 beginHandlingEvents(); |
559 } | 581 } |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
604 return impl.startTracing(categories, recorder); | 626 return impl.startTracing(categories, recorder); |
605 } | 627 } |
606 void stopTracing() { | 628 void stopTracing() { |
607 return impl.stopTracing(); | 629 return impl.stopTracing(); |
608 } | 630 } |
609 } | 631 } |
610 | 632 |
611 const int _traceRecorderMethodRecordName = 0; | 633 const int _traceRecorderMethodRecordName = 0; |
612 | 634 |
613 class _TraceRecorderServiceDescription implements service_describer.ServiceDescr
iption { | 635 class _TraceRecorderServiceDescription implements service_describer.ServiceDescr
iption { |
614 dynamic getTopLevelInterface([Function responseFactory]) => | 636 void getTopLevelInterface(Function responder) { |
615 responseFactory(null); | 637 responder(null); |
| 638 } |
616 | 639 |
617 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 640 void getTypeDefinition(String typeKey, Function responder) { |
618 responseFactory(null); | 641 responder(null); |
| 642 } |
619 | 643 |
620 dynamic getAllTypeDefinitions([Function responseFactory]) => | 644 void getAllTypeDefinitions(Function responder) { |
621 responseFactory(null); | 645 responder(null); |
| 646 } |
622 } | 647 } |
623 | 648 |
624 abstract class TraceRecorder { | 649 abstract class TraceRecorder { |
625 static const String serviceName = null; | 650 static const String serviceName = null; |
626 | 651 |
627 static service_describer.ServiceDescription _cachedServiceDescription; | 652 static service_describer.ServiceDescription _cachedServiceDescription; |
628 static service_describer.ServiceDescription get serviceDescription { | 653 static service_describer.ServiceDescription get serviceDescription { |
629 if (_cachedServiceDescription == null) { | 654 if (_cachedServiceDescription == null) { |
630 _cachedServiceDescription = new _TraceRecorderServiceDescription(); | 655 _cachedServiceDescription = new _TraceRecorderServiceDescription(); |
631 } | 656 } |
(...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
748 : super.fromHandle(handle, autoBegin: impl != null) { | 773 : super.fromHandle(handle, autoBegin: impl != null) { |
749 _impl = impl; | 774 _impl = impl; |
750 } | 775 } |
751 | 776 |
752 _TraceRecorderStubControl.unbound([this._impl]) : super.unbound(); | 777 _TraceRecorderStubControl.unbound([this._impl]) : super.unbound(); |
753 | 778 |
754 String get serviceName => TraceRecorder.serviceName; | 779 String get serviceName => TraceRecorder.serviceName; |
755 | 780 |
756 | 781 |
757 | 782 |
758 dynamic handleMessage(bindings.ServiceMessage message) { | 783 void handleMessage(bindings.ServiceMessage message) { |
759 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 784 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
760 return bindings.ControlMessageHandler.handleMessage(this, | 785 bindings.ControlMessageHandler.handleMessage( |
761 0, | 786 this, 0, message); |
762 message); | 787 return; |
763 } | 788 } |
764 if (_impl == null) { | 789 if (_impl == null) { |
765 throw new core.MojoApiError("$this has no implementation set"); | 790 throw new core.MojoApiError("$this has no implementation set"); |
766 } | 791 } |
767 switch (message.header.type) { | 792 switch (message.header.type) { |
768 case _traceRecorderMethodRecordName: | 793 case _traceRecorderMethodRecordName: |
769 var params = _TraceRecorderRecordParams.deserialize( | 794 var params = _TraceRecorderRecordParams.deserialize( |
770 message.payload); | 795 message.payload); |
771 _impl.record(params.json); | 796 _impl.record(params.json); |
772 break; | 797 break; |
773 default: | 798 default: |
774 throw new bindings.MojoCodecError("Unexpected message name"); | 799 throw new bindings.MojoCodecError("Unexpected message name"); |
775 break; | 800 break; |
776 } | 801 } |
777 return null; | |
778 } | 802 } |
779 | 803 |
780 TraceRecorder get impl => _impl; | 804 TraceRecorder get impl => _impl; |
781 set impl(TraceRecorder d) { | 805 set impl(TraceRecorder d) { |
782 if (d == null) { | 806 if (d == null) { |
783 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 807 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
784 } | 808 } |
785 if (isBound && (_impl == null)) { | 809 if (isBound && (_impl == null)) { |
786 beginHandlingEvents(); | 810 beginHandlingEvents(); |
787 } | 811 } |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
830 | 854 |
831 void record(String json) { | 855 void record(String json) { |
832 return impl.record(json); | 856 return impl.record(json); |
833 } | 857 } |
834 } | 858 } |
835 | 859 |
836 const int _traceCollectorMethodStartName = 0; | 860 const int _traceCollectorMethodStartName = 0; |
837 const int _traceCollectorMethodStopAndFlushName = 1; | 861 const int _traceCollectorMethodStopAndFlushName = 1; |
838 | 862 |
839 class _TraceCollectorServiceDescription implements service_describer.ServiceDesc
ription { | 863 class _TraceCollectorServiceDescription implements service_describer.ServiceDesc
ription { |
840 dynamic getTopLevelInterface([Function responseFactory]) => | 864 void getTopLevelInterface(Function responder) { |
841 responseFactory(null); | 865 responder(null); |
| 866 } |
842 | 867 |
843 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 868 void getTypeDefinition(String typeKey, Function responder) { |
844 responseFactory(null); | 869 responder(null); |
| 870 } |
845 | 871 |
846 dynamic getAllTypeDefinitions([Function responseFactory]) => | 872 void getAllTypeDefinitions(Function responder) { |
847 responseFactory(null); | 873 responder(null); |
| 874 } |
848 } | 875 } |
849 | 876 |
850 abstract class TraceCollector { | 877 abstract class TraceCollector { |
851 static const String serviceName = "tracing::TraceCollector"; | 878 static const String serviceName = "tracing::TraceCollector"; |
852 | 879 |
853 static service_describer.ServiceDescription _cachedServiceDescription; | 880 static service_describer.ServiceDescription _cachedServiceDescription; |
854 static service_describer.ServiceDescription get serviceDescription { | 881 static service_describer.ServiceDescription get serviceDescription { |
855 if (_cachedServiceDescription == null) { | 882 if (_cachedServiceDescription == null) { |
856 _cachedServiceDescription = new _TraceCollectorServiceDescription(); | 883 _cachedServiceDescription = new _TraceCollectorServiceDescription(); |
857 } | 884 } |
(...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
985 : super.fromHandle(handle, autoBegin: impl != null) { | 1012 : super.fromHandle(handle, autoBegin: impl != null) { |
986 _impl = impl; | 1013 _impl = impl; |
987 } | 1014 } |
988 | 1015 |
989 _TraceCollectorStubControl.unbound([this._impl]) : super.unbound(); | 1016 _TraceCollectorStubControl.unbound([this._impl]) : super.unbound(); |
990 | 1017 |
991 String get serviceName => TraceCollector.serviceName; | 1018 String get serviceName => TraceCollector.serviceName; |
992 | 1019 |
993 | 1020 |
994 | 1021 |
995 dynamic handleMessage(bindings.ServiceMessage message) { | 1022 void handleMessage(bindings.ServiceMessage message) { |
996 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 1023 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
997 return bindings.ControlMessageHandler.handleMessage(this, | 1024 bindings.ControlMessageHandler.handleMessage( |
998 0, | 1025 this, 0, message); |
999 message); | 1026 return; |
1000 } | 1027 } |
1001 if (_impl == null) { | 1028 if (_impl == null) { |
1002 throw new core.MojoApiError("$this has no implementation set"); | 1029 throw new core.MojoApiError("$this has no implementation set"); |
1003 } | 1030 } |
1004 switch (message.header.type) { | 1031 switch (message.header.type) { |
1005 case _traceCollectorMethodStartName: | 1032 case _traceCollectorMethodStartName: |
1006 var params = _TraceCollectorStartParams.deserialize( | 1033 var params = _TraceCollectorStartParams.deserialize( |
1007 message.payload); | 1034 message.payload); |
1008 _impl.start(params.stream, params.categories); | 1035 _impl.start(params.stream, params.categories); |
1009 break; | 1036 break; |
1010 case _traceCollectorMethodStopAndFlushName: | 1037 case _traceCollectorMethodStopAndFlushName: |
1011 _impl.stopAndFlush(); | 1038 _impl.stopAndFlush(); |
1012 break; | 1039 break; |
1013 default: | 1040 default: |
1014 throw new bindings.MojoCodecError("Unexpected message name"); | 1041 throw new bindings.MojoCodecError("Unexpected message name"); |
1015 break; | 1042 break; |
1016 } | 1043 } |
1017 return null; | |
1018 } | 1044 } |
1019 | 1045 |
1020 TraceCollector get impl => _impl; | 1046 TraceCollector get impl => _impl; |
1021 set impl(TraceCollector d) { | 1047 set impl(TraceCollector d) { |
1022 if (d == null) { | 1048 if (d == null) { |
1023 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 1049 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
1024 } | 1050 } |
1025 if (isBound && (_impl == null)) { | 1051 if (isBound && (_impl == null)) { |
1026 beginHandlingEvents(); | 1052 beginHandlingEvents(); |
1027 } | 1053 } |
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1071 void start(core.MojoDataPipeProducer stream, String categories) { | 1097 void start(core.MojoDataPipeProducer stream, String categories) { |
1072 return impl.start(stream, categories); | 1098 return impl.start(stream, categories); |
1073 } | 1099 } |
1074 void stopAndFlush() { | 1100 void stopAndFlush() { |
1075 return impl.stopAndFlush(); | 1101 return impl.stopAndFlush(); |
1076 } | 1102 } |
1077 } | 1103 } |
1078 | 1104 |
1079 | 1105 |
1080 | 1106 |
OLD | NEW |