[Cronet] Initial implementation of HttpURLConnection

components/cronet/android/java/src/org/chromium/net/urlconnection/CronetInputStream.java

Index: components/cronet/android/java/src/org/chromium/net/urlconnection/CronetInputStream.java
diff --git a/components/cronet/android/java/src/org/chromium/net/urlconnection/CronetInputStream.java b/components/cronet/android/java/src/org/chromium/net/urlconnection/CronetInputStream.java
new file mode 100644
index 0000000000000000000000000000000000000000..fc72ab11b6c23360b846cca35160d633fce4667f
--- /dev/null
+++ b/components/cronet/android/java/src/org/chromium/net/urlconnection/CronetInputStream.java
@@ -0,0 +1,46 @@
+// Copyright 2014 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+package org.chromium.net.urlconnection;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.ByteBuffer;
+
+/**
+ * An InputStream that is used by {@link CronetHttpURLConnection} to request
+ * data from the network stack as needed.
+ */
+class CronetInputStream extends InputStream {

[mef, 2014/12/04 20:37:56]

nit: Given that CronetUrlRequestListener is a private inner class of
CronetHTTPUrlConnection, should this also be an inner class?
Does it have any use stand alone?

[xunjieli, 2014/12/04 20:55:53]

I don't think there's any use case for it to be used as a stand-alone. I make it
package protected, so it cannot be used outside org.chromium.net.urlconnection.
I was afraid that including this in CronetHttpURLConnection.java will make the
file big and not easy to read. 

+    private final CronetHttpURLConnection mHttpURLConnection;
+    // Indicates whether listener's onSucceeded or onFailed callback is invoked.
+    private boolean mResponseDataCompleted;
+    private ByteBuffer mBuffer;
+
+    /**
+     * Constructs a CronetInputStream.
+     * @param httpURLConnection the CronetHttpURLConnection that is associated
+     *            with this InputStream.
+     */
+    public CronetInputStream(CronetHttpURLConnection httpURLConnection) {
+        mHttpURLConnection = httpURLConnection;
+    }
+
+    @Override
+    public int read() throws IOException {
+        if (!mResponseDataCompleted
+                && (mBuffer == null || !mBuffer.hasRemaining())) {
+            // Requests more data from CronetHttpURLConnection.
+            mBuffer = mHttpURLConnection.getMoreData();
+        }
+        if (mBuffer != null && mBuffer.hasRemaining()) {
+            return mBuffer.get() & 0xFF;
+        }
+        return -1;
+    }
+
+    void setResponseDataCompleted() {
+        mResponseDataCompleted = true;
+    }
+}