| OLD | NEW |
| (Empty) |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 import 'dart:async'; | |
| 6 import 'dart:isolate'; | |
| 7 | |
| 8 import 'package:mojo/core.dart' as core; | |
| 9 | |
| 10 main() { | |
| 11 var pipe = new core.MojoMessagePipe(); | |
| 12 assert(pipe != null); | |
| 13 | |
| 14 var endpoint = pipe.endpoints[0]; | |
| 15 assert(endpoint.handle.isValid); | |
| 16 | |
| 17 var eventSubscription = new core.MojoEventSubscription(endpoint.handle); | |
| 18 var completer = new Completer(); | |
| 19 int numEvents = 0; | |
| 20 | |
| 21 eventSubscription.subscribe((_) { | |
| 22 numEvents++; | |
| 23 eventSubscription.close().then((_) { | |
| 24 completer.complete(numEvents); | |
| 25 }); | |
| 26 }); | |
| 27 eventSubscription.enableWriteEvents(); | |
| 28 | |
| 29 completer.future.then((int numEvents) { | |
| 30 assert(numEvents == 1); | |
| 31 }); | |
| 32 } | |
| OLD | NEW |