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