Chromium Code Reviews| Index: sdk/lib/io/stdio.dart |
| diff --git a/sdk/lib/io/stdio.dart b/sdk/lib/io/stdio.dart |
| index 9c034f437adbca9db958341dea7552cd361eaf79..9d61128d2ce1c567f43321915a8049f1a7ab7824 100644 |
| --- a/sdk/lib/io/stdio.dart |
| +++ b/sdk/lib/io/stdio.dart |
| @@ -40,84 +40,72 @@ class Stdin extends _StdStream implements Stream<List<int>> { |
| /** |
| * Synchronously read a line from stdin. This call will block until a full |
| - * line is available. The line will contain the newline character(s). |
| + * line is available. |
| * |
| - * If end-of-file is reached, `null` is returned. |
| + * The argument [encoding] can be used to changed how the input should be |
| + * decoded. Default is [SYSTEM_ENCODING]. |
| + * |
| + * If [retainNewlines] is `false`, the returned String will not contain the |
| + * final newline. Default is `false`. |
|
Lasse Reichstein Nielsen
2014/04/22 10:56:08
Doesn't say what happens if retainNewlines is true
Anders Johnsen
2014/11/13 16:21:05
Done.
|
| * |
| * If end-of-file is reached after some data has already been read, that data |
|
Lasse Reichstein Nielsen
2014/04/22 10:56:08
How about "after any bytes have been read from std
Anders Johnsen
2014/11/13 16:21:06
Done.
|
| - * is returned. |
| + * is returned. If no data was read, `null` is returned. |
| */ |
| String readLineSync({Encoding encoding: SYSTEM_ENCODING, |
| bool retainNewlines: false}) { |
| const CR = 13; |
| const LF = 10; |
| - var line = new StringBuffer(); |
| - bool end = false; |
| - bool lastCharWasCR = false; |
| - var error; |
| - |
| - StreamController<List<int>> controller = |
| - new StreamController<List<int>>(sync: true); |
| - Stream stream = controller.stream.transform(encoding.decoder); |
| - stream.listen((String str) { |
| - line.write(str); |
| - }, onError: (e) { |
| - error = e; |
| - }, onDone: () { |
| - end = true; |
| - }); |
| - |
| - bool empty = true; |
| - while (!end) { |
| - int b = readByteSync(); |
| - |
| - if (b < 0) { |
| - // We didn't write the carriage return in case a line feed would be |
| - // the next character. Add it now. |
| - if (lastCharWasCR && !retainNewlines) controller.add([CR]); |
| - controller.close(); |
| - } else { |
| - empty = false; |
| - // We consider \r\n and \n as new lines. |
| - // A \r on its own is treated like a normal character. |
| - |
| - if (b == CR) { |
| - if (lastCharWasCR && !retainNewlines) { |
| - // We didn't write the carriage return in case a line feed would be |
| - // the next character. |
| - // Add it now (since we treat it like a normal character now). |
| - controller.add([CR]); |
| - } |
| - // We add the carriage return only if we keep new lines. |
| - // Otherwise we need to wait for the next character (in case it is |
| - // a line feed). |
| - if (retainNewlines) controller.add([b]); |
| - lastCharWasCR = true; |
| - } else if (b == LF) { |
| - end = true; |
| - // We don't care if there was a carriage return before. If we keep |
| - // the line separators it has already been added to the controller. |
| - // Otherwise we don't want it anyway. |
| - if (retainNewlines) controller.add([b]); |
| - controller.close(); |
| - } else { |
| - // Since the current character is not a line feed we flush the |
| - // carriage return we didn't write last iteration. |
| - if (lastCharWasCR) { |
| - controller.add([CR]); |
| - lastCharWasCR = false; |
| - } |
| - controller.add([b]); |
| + final List line = []; |
| + // On Windows, if lineMode is disabled, only CR is received. |
| + bool crIsNewline = Platform.isWindows && |
| + (stdioType(stdin) == StdioType.TERMINAL) && |
| + !lineMode; |
| + if (retainNewlines) { |
| + int byte; |
| + do { |
| + byte = readByteSync(); |
| + if (byte < 0) { |
| + break; |
| + } |
| + line.add(byte); |
| + } while (byte != LF && !(byte == CR && crIsNewline)); |
| + if (line.isEmpty) { |
| + return null; |
| + } |
| + } else if (crIsNewline) { |
| + // CR and LF are both line terminators, neither is retained. |
| + while (true) { |
| + int byte = readByteSync(); |
| + if (byte < 0) { |
| + if (line.isEmpty) return null; |
| + break; |
| } |
| + if (byte == LF || byte == CR) break; |
| + line.add(byte); |
| } |
| - if (error != null) { |
| - // Error during decoding. |
| - throw error; |
| + } else { |
| + // Case having to hande CR LF as a single unretained line terminator. |
| +outer: |
|
Lasse Reichstein Nielsen
2014/04/22 10:56:08
Indent label, and preferably put it on same line a
Anders Johnsen
2014/11/13 16:21:06
Done.
|
| + while (true) { |
| + int byte = readByteSync(); |
| + if (byte == LF) break; |
| + if (byte == CR) { |
| + do { |
| + byte = readByteSync(); |
| + if (byte == LF) break outer; |
| + |
| + line.add(CR); |
| + } while (byte == CR); |
| + // Fall through and handle non-CR character. |
| + } |
| + if (byte < 0) { |
| + if (line.isEmpty) return null; |
| + break; |
| + } |
| + line.add(byte); |
| } |
| } |
| - |
| - if (empty) return null; |
| - return line.toString(); |
| + return encoding.decode(line); |
| } |
| /** |