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