| 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: (_) {});
|
| }
|
|
|
|
|