Index: mojo/dart/test/simple_handle_watcher_test.dart |
diff --git a/mojo/dart/test/simple_handle_watcher_test.dart b/mojo/dart/test/simple_handle_watcher_test.dart |
index d8456ded7ba772cfa6431d4bc9bbaa75dd38c400..b0c04014fa2c09e06cd40b91d9c338e8af016014 100644 |
--- a/mojo/dart/test/simple_handle_watcher_test.dart |
+++ b/mojo/dart/test/simple_handle_watcher_test.dart |
@@ -14,17 +14,17 @@ main() { |
var endpoint = pipe.endpoints[0]; |
assert(endpoint.handle.isValid); |
- var eventStream = new core.MojoEventStream(endpoint.handle); |
+ var eventSubscription = new core.MojoEventSubscription(endpoint.handle); |
var completer = new Completer(); |
int numEvents = 0; |
- eventStream.listen((_) { |
+ eventSubscription.subscribe((_) { |
numEvents++; |
- eventStream.close(); |
- }, onDone: () { |
- completer.complete(numEvents); |
+ eventSubscription.close().then((_) { |
+ completer.complete(numEvents); |
+ }); |
}); |
- eventStream.enableWriteEvents(); |
+ eventSubscription.enableWriteEvents(); |
completer.future.then((int numEvents) { |
assert(numEvents == 1); |