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