Index: sdk/lib/io/mime_multipart_parser.dart |
diff --git a/sdk/lib/io/mime_multipart_parser.dart b/sdk/lib/io/mime_multipart_parser.dart |
index dc3f2069e8fb4377d685772cf0229ff1ae844973..4bfbebe2a6151286345d8e3101f2f7dc6b263002 100644 |
--- a/sdk/lib/io/mime_multipart_parser.dart |
+++ b/sdk/lib/io/mime_multipart_parser.dart |
@@ -101,10 +101,11 @@ class MimeMultipartTransformer |
Stream<MimeMultipart> bind(Stream<List<int>> stream) { |
_controller = new StreamController( |
- onPause: _pauseStream, |
- onResume:_resumeStream, |
- onCancel: () { |
- _subscription.cancel(); |
+ onPause: () { |
+ _pauseStream(); |
+ }, |
+ onResume: () { |
+ _resumeStream(); |
}, |
onListen: () { |
_subscription = stream.listen( |
@@ -125,6 +126,9 @@ class MimeMultipartTransformer |
onError: (error) { |
_controller.addError(error); |
}); |
+ }, |
+ onCancel: () { |
+ _subscription.cancel(); |
}); |
return _controller.stream; |
} |