Prepare the HTTP library for inclusion in the standalone VM (step 2)

runtime/bin/stream_util.dart

 // Copyright (c) 2012, 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.
 
 class _BaseDataInputStream {
   abstract int available();
 
   List<int> read([int len]) {
     if (_closeCallbackCalled) return null;
     int bytesToRead = available();
@@ skipping 18 matching lines @@
     if (len < 0) throw new StreamException("Illegal length $len");
     int bytesToRead = Math.min(len, available());
     return _readInto(buffer, offset, bytesToRead);
   }
 
   void pipe(OutputStream output, [bool close = true]) {
     _pipe(this, output, close: close);
   }
 
   void close() {
-    if (_scheduledDataCallback != null) {
-      _scheduledDataCallback.cancel();
-    }
+    _cancelScheduledDataCallback();
     _close();
     _checkScheduleCallbacks();
   }
 
   bool get closed() => _closeCallbackCalled;
 
   void set dataHandler(void callback()) {
     _clientDataHandler = callback;
     _checkScheduleCallbacks();
   }
 
   void set closeHandler(void callback()) {
     _clientCloseHandler = callback;
     _checkScheduleCallbacks();
   }
 
   void set errorHandler(void callback()) {
     _clientErrorHandler = callback;
   }
 
   abstract List<int> _read(int bytesToRead);
 
+  void _dataReceived() {
+    // More data has been received asynchronously. Perform the data
+    // handler callback now.
+    _cancelScheduledDataCallback();
+    if (_clientDataHandler !== null) {
+      _clientDataHandler();
+    }
+    _checkScheduleCallbacks();
+  }
+
+  void _closeReceived() {
+    // Close indication has been received asynchronously. Perform the
+    // close callback now if all data has been delivered.
+    _streamMarkedClosed = true;
+    if (available() == 0) {
+      if (_clientCloseHandler !== null) {
+        _clientCloseHandler();
+        _closeCallbackCalled = true;
+      }
+    } else {
+      _checkScheduleCallbacks();
+    }
+  }
+
+  void _cancelScheduledDataCallback() {
+    if (_scheduledDataCallback != null) {
+      _scheduledDataCallback.cancel();
+      _scheduledDataCallback = null;
+    }
+  }
+
   void _checkScheduleCallbacks() {
     void issueDataCallback(Timer timer) {
       _scheduledDataCallback = null;
       if (_clientDataHandler !== null) {
         _clientDataHandler();
         _checkScheduleCallbacks();
       }
     }
 
     void issueCloseCallback(Timer timer) {
       _scheduledCloseCallback = null;
       if (_clientCloseHandler !== null) _clientCloseHandler();
     }
 
     // Schedule data callback if there is more data to read. Schedule
     // close callback once when all data has been read. Only schedule
     // a new callback if the previous one has actually been called.
     if (!_closeCallbackCalled) {
       if (available() > 0) {
         if (_scheduledDataCallback == null) {
           _scheduledDataCallback = new Timer(issueDataCallback, 0);
         }
       } else if (_streamMarkedClosed && !_closeCallbackCalled) {
-        if (_scheduledDataCallback != null) {
-          _scheduledDataCallback.cancel();
-        }
+        _cancelScheduledDataCallback();
         _close();
         _scheduledCloseCallback = new Timer(issueCloseCallback, 0);
         _closeCallbackCalled = true;
       }
     }
   }
 
   // When this is set to true the stream is marked closed. When a
   // stream is marked closed no more data can arrive and the value
   // from available is now all remaining data. If this is true and the
@@ skipping 41 matching lines @@
     input.dataHandler = pipeDataHandler;
     output.noPendingWriteHandler = null;
   };
 
   _inputCloseHandler = input._clientCloseHandler;
   input.dataHandler = pipeDataHandler;
   input.closeHandler = pipeCloseHandler;
   output.noPendingWriteHandler = null;
 }