Add Stdio.readByteSync and Stdio.readLineSync.

sdk/lib/io/stdio.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;
 
 const int _STDIO_HANDLE_TYPE_TERMINAL = 0;
 const int _STDIO_HANDLE_TYPE_PIPE = 1;
 const int _STDIO_HANDLE_TYPE_FILE = 2;
 const int _STDIO_HANDLE_TYPE_SOCKET = 3;
 const int _STDIO_HANDLE_TYPE_OTHER = 4;
 
+
 class _StdStream extends Stream<List<int>> {
   final Stream<List<int>> _stream;
 
   _StdStream(Stream<List<int>> this._stream);
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
                                        {void onError(error),
                                         void onDone(),
                                         bool cancelOnError}) {
     return _stream.listen(
         onData,
         onError: onError,
         onDone: onDone,
         cancelOnError: cancelOnError);
   }
 }
 
+
+class _StdinEventSink {
+  Function add;
+  Function addError;
+  Function close;
+  _StdinEventSink(this.add, this.addError, this.close);
+}
+
+/**
+ * [Stdin] class that enable both synchronous and asynchronous reads from the
+ * stdin pipe.
+ *
+ * Mixing synchronous and asynchronous reads is undefined.
+ */
+class Stdin extends _StdStream {
+  Stdin._(Stream<List<int>> stream) : super(stream);
+
+  /**
+   * Read a line from stdin. This call will block until a full line is
+   * available. The line will contain the newline character(s).
+   *
+   * If at end of file, `null` is returned.
+   *
+   * If at end of file, while some data is already read, that data is returned.
+   */
+  String readLineSync({Encoding encoding: Encoding.SYSTEM,
+                       bool retainNewlines: false}) {
+    var decoder = new StringDecoder(encoding)._decoder;
+    var line = new StringBuffer();
+    bool end = false;
+    var sink = new _StdinEventSink(
+        (chunk) {

[Bill Hesse, 2013/07/02 11:31:54]

Why is chunk not char, or rune?  It seems misleading, like it could be more than
a single char.

[Anders Johnsen, 2013/07/02 12:21:27]

Done.

+          if (chunk == '\n') end = true;
+          line.write(chunk);
+        },
+        (error) {
+          throw error;
+        }, () {});
+
+    while (!end) {
+      int b = readByteSync();
+      if (b >= 0) {
+        decoder.handleData([b], sink);
+      } else {
+        decoder.handleDone(sink);
+        break;
+      }
+    }
+
+    if (line.isEmpty) return null;
+    line = line.toString();
+    int trim = 0;
+    if (!retainNewlines) {

[Bill Hesse, 2013/07/02 11:31:54]

I would have put this into the sink object, with more logic and a
"lastCharWasCR" bool.  I think it is not too complex to put it there, and reads
better.

[Anders Johnsen, 2013/07/02 12:21:27]

Done.

+      if (line.endsWith('\r\n')) {
+        trim = 2;
+      } else if (line.endsWith('\n')) {
+        trim = 1;
+      }
+    }
+    return line.substring(0, line.length - trim);
+  }
+
+  /**
+   * Read a byte from stdin. This call will block until a byte is available.
+   *
+   * If at end of file, -1 is returned.
+   */
+  int readByteSync();
+}
+
+
 class _StdSink implements IOSink {
   final IOSink _sink;
 
   _StdSink(IOSink this._sink);
 
   Encoding get encoding => _sink.encoding;
   void set encoding(Encoding encoding) {
     _sink.encoding = encoding;
   }
   void write(object) => _sink.write(object);
@@ skipping 74 matching lines @@
   }
   return StdioType.OTHER;
 }
 
 
 class _StdIOUtils {
   external static IOSink _getStdioOutputStream(int fd);
   external static Stream<List<int>> _getStdioInputStream();
   external static int _socketType(nativeSocket);
 }