Chromium Code Reviews| Index: lib/src/utils.dart |
| diff --git a/lib/src/utils.dart b/lib/src/utils.dart |
| index bc5a2701e9dbe16aff2b2c337f36061191cf9f71..4dccea6e76a90f70f83032ccf811906e80dd2789 100644 |
| --- a/lib/src/utils.dart |
| +++ b/lib/src/utils.dart |
| @@ -27,8 +27,12 @@ typedef AsyncFunction(); |
| /// A typedef for a zero-argument callback function. |
| typedef void Callback(); |
| -/// A converter that decodes bytes using UTF-8 and splits them on newlines. |
| -final lineSplitter = UTF8.decoder.fuse(const LineSplitter()); |
| +/// A transformer that decodes bytes using UTF-8 and splits them on newlines. |
| +final StreamTransformer<List<int>, String> lineSplitter = new StreamTransformer( |
|
nweiz
2016/06/23 22:22:47
You can probably avoid type-annotating this, too,
kevmoo
2016/06/23 22:32:28
Just putting types on the right seems to do the tr
|
| + (Stream<List<int>> stream, bool cancelOnError) => stream |
|
nweiz
2016/06/23 22:22:47
Don't type-annotate these. They should be inferred
kevmoo
2016/06/23 22:32:28
Done.
|
| + .transform(UTF8.decoder) |
| + .transform(const LineSplitter()) |
| + .listen(null, cancelOnError: cancelOnError)); |
| /// A regular expression to match the exception prefix that some exceptions' |
| /// [Object.toString] values contain. |