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 1704 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1715 | 1715 |
1716 ServiceEvent.connectionClosed(this.reason) : super._empty(null) { | 1716 ServiceEvent.connectionClosed(this.reason) : super._empty(null) { |
1717 kind = kConnectionClosed; | 1717 kind = kConnectionClosed; |
1718 } | 1718 } |
1719 | 1719 |
1720 @observable String kind; | 1720 @observable String kind; |
1721 @observable Breakpoint breakpoint; | 1721 @observable Breakpoint breakpoint; |
1722 @observable Frame topFrame; | 1722 @observable Frame topFrame; |
1723 @observable Instance exception; | 1723 @observable Instance exception; |
1724 @observable Instance asyncContinuation; | 1724 @observable Instance asyncContinuation; |
| 1725 @observable bool atAsyncJump; |
1725 @observable ServiceObject inspectee; | 1726 @observable ServiceObject inspectee; |
1726 @observable ByteData data; | 1727 @observable ByteData data; |
1727 @observable int count; | 1728 @observable int count; |
1728 @observable String reason; | 1729 @observable String reason; |
1729 @observable String exceptions; | 1730 @observable String exceptions; |
1730 @observable String bytesAsString; | 1731 @observable String bytesAsString; |
1731 @observable Map logRecord; | 1732 @observable Map logRecord; |
1732 int chunkIndex, chunkCount, nodeCount; | 1733 int chunkIndex, chunkCount, nodeCount; |
1733 | 1734 |
1734 @observable bool get isPauseEvent { | 1735 @observable bool get isPauseEvent { |
(...skipping 22 matching lines...) Expand all Loading... |
1757 if (pauseBpts.length > 0) { | 1758 if (pauseBpts.length > 0) { |
1758 breakpoint = pauseBpts[0]; | 1759 breakpoint = pauseBpts[0]; |
1759 } | 1760 } |
1760 } | 1761 } |
1761 topFrame = map['topFrame']; | 1762 topFrame = map['topFrame']; |
1762 if (map['exception'] != null) { | 1763 if (map['exception'] != null) { |
1763 exception = map['exception']; | 1764 exception = map['exception']; |
1764 } | 1765 } |
1765 if (map['_asyncContinuation'] != null) { | 1766 if (map['_asyncContinuation'] != null) { |
1766 asyncContinuation = map['_asyncContinuation']; | 1767 asyncContinuation = map['_asyncContinuation']; |
| 1768 atAsyncJump = map['_atAsyncJump']; |
| 1769 } else { |
| 1770 atAsyncJump = false; |
1767 } | 1771 } |
1768 if (map['inspectee'] != null) { | 1772 if (map['inspectee'] != null) { |
1769 inspectee = map['inspectee']; | 1773 inspectee = map['inspectee']; |
1770 } | 1774 } |
1771 if (map['_data'] != null) { | 1775 if (map['_data'] != null) { |
1772 data = map['_data']; | 1776 data = map['_data']; |
1773 } | 1777 } |
1774 if (map['chunkIndex'] != null) { | 1778 if (map['chunkIndex'] != null) { |
1775 chunkIndex = map['chunkIndex']; | 1779 chunkIndex = map['chunkIndex']; |
1776 } | 1780 } |
(...skipping 1859 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3636 assert(!mapIsRef); | 3640 assert(!mapIsRef); |
3637 _loaded = true; | 3641 _loaded = true; |
3638 _upgradeCollection(map, owner); | 3642 _upgradeCollection(map, owner); |
3639 this.index = map['index']; | 3643 this.index = map['index']; |
3640 this.function = map['function']; | 3644 this.function = map['function']; |
3641 this.location = map['location']; | 3645 this.location = map['location']; |
3642 this.code = map['code']; | 3646 this.code = map['code']; |
3643 this.variables = map['vars']; | 3647 this.variables = map['vars']; |
3644 } | 3648 } |
3645 | 3649 |
3646 String toString() => "Frame(${function.qualifiedName})"; | 3650 String toString() => "Frame(${function.qualifiedName} $location)"; |
3647 } | 3651 } |
3648 | 3652 |
3649 | 3653 |
3650 class ServiceMessage extends ServiceObject { | 3654 class ServiceMessage extends ServiceObject { |
3651 @observable int index; | 3655 @observable int index; |
3652 @observable String messageObjectId; | 3656 @observable String messageObjectId; |
3653 @observable int size; | 3657 @observable int size; |
3654 @observable ServiceFunction handler; | 3658 @observable ServiceFunction handler; |
3655 @observable SourceLocation location; | 3659 @observable SourceLocation location; |
3656 | 3660 |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3709 var v = list[i]; | 3713 var v = list[i]; |
3710 if ((v is ObservableMap) && _isServiceMap(v)) { | 3714 if ((v is ObservableMap) && _isServiceMap(v)) { |
3711 list[i] = owner.getFromMap(v); | 3715 list[i] = owner.getFromMap(v); |
3712 } else if (v is ObservableList) { | 3716 } else if (v is ObservableList) { |
3713 _upgradeObservableList(v, owner); | 3717 _upgradeObservableList(v, owner); |
3714 } else if (v is ObservableMap) { | 3718 } else if (v is ObservableMap) { |
3715 _upgradeObservableMap(v, owner); | 3719 _upgradeObservableMap(v, owner); |
3716 } | 3720 } |
3717 } | 3721 } |
3718 } | 3722 } |
OLD | NEW |