| OLD | NEW |
| 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 part of service; | 5 part of service; |
| 6 | 6 |
| 7 /// Helper function for canceling a Future<StreamSubscription>. | 7 /// Helper function for canceling a Future<StreamSubscription>. |
| 8 Future cancelFutureSubscription( | 8 Future cancelFutureSubscription( |
| 9 Future<StreamSubscription> subscriptionFuture) async { | 9 Future<StreamSubscription> subscriptionFuture) async { |
| 10 if (subscriptionFuture != null) { | 10 if (subscriptionFuture != null) { |
| (...skipping 785 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 796 }); | 796 }); |
| 797 } | 797 } |
| 798 | 798 |
| 799 void _dispatchEventToIsolate(ServiceEvent event) { | 799 void _dispatchEventToIsolate(ServiceEvent event) { |
| 800 var isolate = event.isolate; | 800 var isolate = event.isolate; |
| 801 if (isolate != null) { | 801 if (isolate != null) { |
| 802 isolate._onEvent(event); | 802 isolate._onEvent(event); |
| 803 } | 803 } |
| 804 } | 804 } |
| 805 | 805 |
| 806 Future restart() { |
| 807 return invokeRpc('_restartVM', {}); |
| 808 } |
| 809 |
| 806 Future<ObservableMap> _fetchDirect() async { | 810 Future<ObservableMap> _fetchDirect() async { |
| 807 if (!loaded) { | 811 if (!loaded) { |
| 808 // The vm service relies on these events to keep the VM and | 812 // The vm service relies on these events to keep the VM and |
| 809 // Isolate types up to date. | 813 // Isolate types up to date. |
| 810 await listenEventStream(kIsolateStream, _dispatchEventToIsolate); | 814 await listenEventStream(kIsolateStream, _dispatchEventToIsolate); |
| 811 await listenEventStream(kDebugStream, _dispatchEventToIsolate); | 815 await listenEventStream(kDebugStream, _dispatchEventToIsolate); |
| 812 await listenEventStream(_kGraphStream, _dispatchEventToIsolate); | 816 await listenEventStream(_kGraphStream, _dispatchEventToIsolate); |
| 813 } | 817 } |
| 814 return await invokeRpcNoUpgrade('getVM', {}); | 818 return await invokeRpcNoUpgrade('getVM', {}); |
| 815 } | 819 } |
| (...skipping 3112 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3928 var v = list[i]; | 3932 var v = list[i]; |
| 3929 if ((v is ObservableMap) && _isServiceMap(v)) { | 3933 if ((v is ObservableMap) && _isServiceMap(v)) { |
| 3930 list[i] = owner.getFromMap(v); | 3934 list[i] = owner.getFromMap(v); |
| 3931 } else if (v is ObservableList) { | 3935 } else if (v is ObservableList) { |
| 3932 _upgradeObservableList(v, owner); | 3936 _upgradeObservableList(v, owner); |
| 3933 } else if (v is ObservableMap) { | 3937 } else if (v is ObservableMap) { |
| 3934 _upgradeObservableMap(v, owner); | 3938 _upgradeObservableMap(v, owner); |
| 3935 } | 3939 } |
| 3936 } | 3940 } |
| 3937 } | 3941 } |
| OLD | NEW |