Converted Observatory heap-snapshot element

runtime/observatory/lib/object_graph.dart

 // Copyright (c) 2014, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 library object_graph;
 
 import 'dart:async';
 import 'dart:collection';
 import 'dart:typed_data';
 
@@ skipping 344 matching lines @@
     var result = _mostRetained;
     if (classId != null) {
       result = result.where((u) => u.vmCid == classId);
     }
     if (limit != null) {
       result = result.take(limit);
     }
     return result;
   }
 
-  Future process(statusReporter) async {
-    // We build futures here instead of marking the steps as async to avoid the
-    // heavy lifting being inside a transformed method.
+  Stream<List> process() {
+    final controller = new StreamController<List>.broadcast();
+    (() async {
+      // We build futures here instead of marking the steps as async to avoid the
+      // heavy lifting being inside a transformed method.
 
-    statusReporter.add("Remapping $_N objects...");
-    await new Future(() => _remapNodes());
+      controller.add(["Remapping $_N objects...", 0.0]);
+      await new Future(() => _remapNodes());
 
-    statusReporter.add("Remapping $_E references...");
-    await new Future(() => _remapEdges());
+      controller.add(["Remapping $_E references...", 15.0]);
+      await new Future(() => _remapEdges());
 
-    _addrToId = null;
-    _chunks = null;
+      _addrToId = null;
+      _chunks = null;
 
-    statusReporter.add("Finding depth-first order...");
-    await new Future(() => _dfs());
+      controller.add(["Finding depth-first order...", 30.0]);
+      await new Future(() => _dfs());
 
-    statusReporter.add("Finding predecessors...");
-    await new Future(() => _buildPredecessors());
+      controller.add(["Finding predecessors...", 45.0]);
+      await new Future(() => _buildPredecessors());
 
-    statusReporter.add("Finding dominators...");
-    await new Future(() => _buildDominators());
+      controller.add(["Finding dominators...", 60.0]);
+      await new Future(() => _buildDominators());
 
-    _firstPreds = null;
-    _preds = null;
+      _firstPreds = null;
+      _preds = null;
 
-    _semi = null;
-    _parent = null;
+      _semi = null;
+      _parent = null;
 
-    statusReporter.add("Finding retained sizes...");
-    await new Future(() => _calculateRetainedSizes());
+      controller.add(["Finding retained sizes...", 75.0]);
+      await new Future(() => _calculateRetainedSizes());
 
-    _vertex = null;
+      _vertex = null;
 
-    statusReporter.add("Loaded");
-    return this;
+      controller.add(["Loaded", 100.0]);
+      controller.close();
+    }());
+    return controller.stream;
   }
 
   List<ByteData> _chunks;
 
   int _kObjectAlignment;
   int _N;
   int _E;
   int _size;
 
   // Indexed by node id, with id 0 representing invalid/uninitialized.
@@ skipping 402 matching lines @@
     for (var i = N; i > 1; i--) {
       var v = vertex[i];
       assert(v != 1);
       retainedSizes[doms[i]] += retainedSizes[i];
     }
 
     _retainedSizes = retainedSizes;
     _size = size;
   }
 }