| 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();
|
|
|