Index: third_party/mojo/src/mojo/public/dart/src/event_stream.dart |
diff --git a/third_party/mojo/src/mojo/public/dart/src/event_stream.dart b/third_party/mojo/src/mojo/public/dart/src/event_stream.dart |
index 7016b3115b1984c9010c344d3656d83afc982296..610285a358d3eed64f1e5f6c4d236a1b0bb203c6 100644 |
--- a/third_party/mojo/src/mojo/public/dart/src/event_stream.dart |
+++ b/third_party/mojo/src/mojo/public/dart/src/event_stream.dart |
@@ -16,7 +16,7 @@ class MojoEventStream extends Stream<int> { |
// events. |
SendPort _sendPort; |
- // The receive port on which we listen and receive events from the handle |
+ // The receive port on which we listen and receive events from the handle |
// watcher. |
ReceivePort _receivePort; |
@@ -118,8 +118,11 @@ class MojoEventStream extends Stream<int> { |
String toString() => "$_handle"; |
} |
+abstract class Listener { |
+ StreamSubscription<List<int>> listen(); |
+} |
-class MojoEventStreamListener { |
+class MojoEventStreamListener implements Listener { |
MojoMessagePipeEndpoint _endpoint; |
MojoEventStream _eventStream; |
bool _isOpen = false; |
@@ -155,7 +158,7 @@ class MojoEventStreamListener { |
_isOpen = false; |
} |
- StreamSubscription<int> listen() { |
+ StreamSubscription<List<int>> listen() { |
_isOpen = true; |
return _eventStream.listen((List<int> event) { |
var signalsWatched = new MojoHandleSignals(event[0]); |