Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(214)

Unified Diff: lib/src/stream_manager.dart

Issue 1670283002: add sendRequest to VMIsolateRef Base URL: git@github.com:yjbanov/vm_service_client.git@master
Patch Set: address comments 2 Created 4 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « lib/src/scope.dart ('k') | test/isolate_test.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: lib/src/stream_manager.dart
diff --git a/lib/src/stream_manager.dart b/lib/src/stream_manager.dart
index 038a4ae992ed19ae003c9343162789ff17ae2759..be7a144ce64d48291b2e8a3d765b5dca873fc8bf 100644
--- a/lib/src/stream_manager.dart
+++ b/lib/src/stream_manager.dart
@@ -41,6 +41,10 @@ class StreamManager {
Stream<Map> get stderr => _stderrController.stream;
StreamController<Map> _stderrController;
+ /// Custom events posted via `postEvent` from the `dart:developer` package.
+ Stream<Map> get extension => _extensionController.stream;
+ StreamController<Map> _extensionController;
+
/// A subscription to [debug].
///
/// This subscription fires no events, but it exists as long as there's also a
@@ -54,6 +58,7 @@ class StreamManager {
_gcController = _controller("GC");
_stdoutController = _controller("Stdout");
_stderrController = _controller("Stderr");
+ _extensionController = _controller("Extension");
_peer.registerMethod("streamNotify", (params) {
switch (params["streamId"].asString) {
@@ -75,6 +80,9 @@ class StreamManager {
case "Stderr":
_stderrController.add(params["event"].asMap);
break;
+ case "Extension":
+ _extensionController.add(params["event"].asMap);
+ break;
}
});
@@ -85,6 +93,7 @@ class StreamManager {
_gcController.close();
_stderrController.close();
_stdoutController.close();
+ _extensionController.close();
}, onError: (_) {});
}
« no previous file with comments | « lib/src/scope.dart ('k') | test/isolate_test.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698