| Index: mojo/dart/packages/mojo/lib/src/event_stream.dart
|
| diff --git a/mojo/dart/packages/mojo/lib/src/event_stream.dart b/mojo/dart/packages/mojo/lib/src/event_stream.dart
|
| index 51708259a3a9f98c9b83c237ebd95ebcd406e99e..ea3e5f513319dc1e91491e538736f8f29edf688f 100644
|
| --- a/mojo/dart/packages/mojo/lib/src/event_stream.dart
|
| +++ b/mojo/dart/packages/mojo/lib/src/event_stream.dart
|
| @@ -149,16 +149,21 @@ class MojoEventHandler {
|
| bool _isInHandler = false;
|
| bool _isPeerClosed = false;
|
|
|
| - MojoEventHandler.fromEndpoint(MojoMessagePipeEndpoint endpoint)
|
| + MojoEventHandler.fromEndpoint(MojoMessagePipeEndpoint endpoint,
|
| + {bool autoBegin: true})
|
| : _endpoint = endpoint,
|
| _eventSubscription = new MojoEventSubscription(endpoint.handle) {
|
| - beginHandlingEvents();
|
| + if (autoBegin) {
|
| + beginHandlingEvents();
|
| + }
|
| }
|
|
|
| - MojoEventHandler.fromHandle(MojoHandle handle)
|
| + MojoEventHandler.fromHandle(MojoHandle handle, {bool autoBegin: true})
|
| : _endpoint = new MojoMessagePipeEndpoint(handle),
|
| _eventSubscription = new MojoEventSubscription(handle) {
|
| - beginHandlingEvents();
|
| + if (autoBegin) {
|
| + beginHandlingEvents();
|
| + }
|
| }
|
|
|
| MojoEventHandler.unbound();
|
|
|