| Index: runtime/observatory/lib/src/repositories/heap_snapshot.dart
|
| diff --git a/runtime/observatory/lib/src/repositories/heap_snapshot.dart b/runtime/observatory/lib/src/repositories/heap_snapshot.dart
|
| index 04891975ce198709e850d05edc895a62586756b6..e56b352a4e0c9c3a99bd7abf4178383a94b8dc47 100644
|
| --- a/runtime/observatory/lib/src/repositories/heap_snapshot.dart
|
| +++ b/runtime/observatory/lib/src/repositories/heap_snapshot.dart
|
| @@ -5,7 +5,7 @@
|
| part of repositories;
|
|
|
| class HeapSnapshotLoadingProgressEvent
|
| - implements M.HeapSnapshotLoadingProgressEvent {
|
| + implements M.HeapSnapshotLoadingProgressEvent {
|
| final HeapSnapshotLoadingProgress progress;
|
| HeapSnapshotLoadingProgressEvent(this.progress);
|
| }
|
| @@ -13,8 +13,7 @@ class HeapSnapshotLoadingProgressEvent
|
| class HeapSnapshotLoadingProgress extends M.HeapSnapshotLoadingProgress {
|
| StreamController<HeapSnapshotLoadingProgressEvent> _onProgress =
|
| new StreamController<HeapSnapshotLoadingProgressEvent>.broadcast();
|
| - Stream<HeapSnapshotLoadingProgressEvent> get onProgress =>
|
| - _onProgress.stream;
|
| + Stream<HeapSnapshotLoadingProgressEvent> get onProgress => _onProgress.stream;
|
|
|
| final S.Isolate isolate;
|
| final bool gc;
|
| @@ -23,7 +22,7 @@ class HeapSnapshotLoadingProgress extends M.HeapSnapshotLoadingProgress {
|
| String _stepDescription = '';
|
| double _progress = 0.0;
|
| final Stopwatch _fetchingTime = new Stopwatch();
|
| - final Stopwatch _loadingTime = new Stopwatch();
|
| + final Stopwatch _loadingTime = new Stopwatch();
|
| HeapSnapshot _snapshot;
|
|
|
| M.HeapSnapshotLoadingStatus get status => _status;
|
| @@ -34,7 +33,7 @@ class HeapSnapshotLoadingProgress extends M.HeapSnapshotLoadingProgress {
|
| HeapSnapshot get snapshot => _snapshot;
|
|
|
| HeapSnapshotLoadingProgress(this.isolate, this.gc) {
|
| - _run();
|
| + _run();
|
| }
|
|
|
| Future _run() async {
|
| @@ -51,7 +50,7 @@ class HeapSnapshotLoadingProgress extends M.HeapSnapshotLoadingProgress {
|
| if (status is List) {
|
| _progress = status[0] * 100.0 / status[1];
|
| _stepDescription = 'Receiving snapshot chunk ${status[0] + 1}'
|
| - ' of ${status[1]}...';
|
| + ' of ${status[1]}...';
|
| _triggerOnProgress();
|
| }
|
| });
|
| @@ -91,7 +90,7 @@ class HeapSnapshotLoadingProgress extends M.HeapSnapshotLoadingProgress {
|
|
|
| void reuse() {
|
| _onProgress =
|
| - new StreamController<HeapSnapshotLoadingProgressEvent>.broadcast();
|
| + new StreamController<HeapSnapshotLoadingProgressEvent>.broadcast();
|
| (() async {
|
| _triggerOnProgress();
|
| _onProgress.close();
|
| @@ -99,11 +98,9 @@ class HeapSnapshotLoadingProgress extends M.HeapSnapshotLoadingProgress {
|
| }
|
| }
|
|
|
| -class HeapSnapshotRepository
|
| - implements M.HeapSnapshotRepository {
|
| -
|
| +class HeapSnapshotRepository implements M.HeapSnapshotRepository {
|
| Stream<HeapSnapshotLoadingProgressEvent> get(M.IsolateRef i,
|
| - {bool gc: false}) {
|
| + {bool gc: false}) {
|
| S.Isolate isolate = i as S.Isolate;
|
| assert(isolate != null);
|
| assert(gc != null);
|
|
|