Detect EOF when reading stdio from terminal on Mac OS

runtime/bin/socket_patch.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.
 
 patch class RawServerSocket  {
   /* patch */ static Future<RawServerSocket> bind(address,
                                                   int port,
                                                   {int backlog: 0,
                                                    bool v6Only: false}) {
     return _RawServerSocket.bind(address, port, backlog, v6Only);
@@ skipping 1006 matching lines @@
 
   void _onPauseStateChange() {
     if (_raw != null) {
       _raw.readEventsEnabled = !_controller.isPaused;
     }
   }
 
   void _onData(event) {
     switch (event) {
       case RawSocketEvent.READ:
-        var buffer = _raw.read();
-        if (buffer != null) _controller.add(buffer);
+        // On Mac OS the end of file on stdin, when connected to a terminal,
+        // is detected by readling less bytes than available on the socket. A
+        // Ctrl-D does not generate a read close event.
+        if (Platform.operatingSystem == "macos") {

[Anders Johnsen, 2013/06/20 12:10:48]

Platform.isMacos :)

[Søren Gjesse, 2013/06/25 10:17:41]

Done (that was actually why I added isMacOS to Platform).

+           var available = _raw.available();
+           if (available == 0) return;
+           var buffer = _raw.read();
+           if (buffer != null) _controller.add(buffer);
+           // If less bytes than available was read this is end of file.
+           if (buffer == null || buffer.length < available) {
+             _controllerClosed = true;
+             _controller.close();
+           }
+        } else {
+          var buffer = _raw.read();
+          if (buffer != null) _controller.add(buffer);
+        }
         break;
       case RawSocketEvent.WRITE:
         _consumer.write();
         break;
       case RawSocketEvent.READ_CLOSED:
         _controllerClosed = true;
         _controller.close();
         break;
     }
   }
@@ skipping 32 matching lines @@
     if (_detachReady != null) {
       _detachReady.complete(null);
     } else {
       if (_raw != null) {
         _raw.shutdown(SocketDirection.SEND);
         _disableWriteEvent();
       }
     }
   }
 }