Index: mojo/public/dart/mojo/lib/src/event_stream.dart |
diff --git a/mojo/public/dart/mojo/lib/src/event_stream.dart b/mojo/public/dart/mojo/lib/src/event_stream.dart |
index 095564a9a4ebed0d70c594038984c8b537baeba5..c56e1ad4f54c1ef41651f6e1a2f3e16e7a0d8df6 100644 |
--- a/mojo/public/dart/mojo/lib/src/event_stream.dart |
+++ b/mojo/public/dart/mojo/lib/src/event_stream.dart |
@@ -31,7 +31,7 @@ class MojoEventStream extends Stream<List<int>> { |
: _handle = handle, |
_signals = signals, |
_isListening = false { |
- MojoResult result = MojoHandle.register(this); |
+ MojoResult result = MojoHandle.registerFinalizer(this); |
if (!result.isOk) { |
throw "Failed to register the MojoHandle: $result."; |
} |
@@ -98,6 +98,7 @@ class MojoEventStream extends Stream<List<int>> { |
Future _handleWatcherClose({bool immediate: false}) { |
assert(_handle != null); |
assert(MojoHandle._removeUnclosedHandle(_handle)); |
+ MojoHandleNatives.removeUnclosed(_handle.h); |
return MojoHandleWatcher.close(_handle.h, wait: !immediate).then((r) { |
if (_receivePort != null) { |
_receivePort.close(); |