Change StreamController constructor.

sdk/lib/io/file_impl.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 part of dart.io;
 
 // Read the file in blocks of size 64k.
 const int _BLOCK_SIZE = 64 * 1024;
 
 
@@ skipping 29 matching lines @@
                                         void onDone(),
                                         bool unsubscribeOnError}) {
     return _controller.stream.listen(onData,
                                      onError: onError,
                                      onDone: onDone,
                                      unsubscribeOnError: unsubscribeOnError);
   }
 
   void _setupController() {
     _controller = new StreamController<List<int>>(
-        onSubscriptionStateChange: _onSubscriptionStateChange,
-        onPauseStateChange: _onPauseStateChange);
+        onListen: _start,
+        onPause: () => _paused = true,
+        onResume: _resume,
+        onCancel: () {
+          _unsubscribed = true;
+          _closeFile();
+        });
   }
 
   Future _closeFile() {
     Future closeFuture;
     if (_openedFile != null) {
       Future closeFuture = _openedFile.close();
       _openedFile = null;
       return closeFuture;
     } else {
       return new Future.immediate(null);
@@ skipping 59 matching lines @@
 
   void _resume() {
     _paused = false;
     if (_currentBlock != null) {
       _controller.add(_currentBlock);
       _currentBlock = null;
     }
     // Resume reading unless we are already done.
     if (_openedFile != null) _readBlock();
   }
-
-  void _onSubscriptionStateChange() {
-    if (_controller.hasListener) {
-      _start();
-    } else {
-      _unsubscribed = true;
-      _closeFile();
-    }
-  }
-
-  void _onPauseStateChange() {
-    if (_controller.isPaused) {
-      _paused = true;
-    } else {
-      _resume();
-    }
-  }
 }
 
 class _FileStreamConsumer extends StreamConsumer<List<int>> {
   File _file;
   Future<RandomAccessFile> _openFuture;
   StreamSubscription _subscription;
 
   _FileStreamConsumer(File this._file, FileMode mode) {
     _openFuture = _file.open(mode: mode);
   }
@@ skipping 896 matching lines @@
           new FileIOException("File closed '$_path'"));
     });
     return completer.future;
   }
 
   final String _path;
   int _id;
 
   SendPort _fileService;
 }