Added two progress indicators to inform of the upload/download of byt…

src/main/java/com/android/volley/toolbox/HurlStack.java

@@ -25,6 +25,7 @@
 import java.io.FilterInputStream;
 import java.io.IOException;
 import java.io.InputStream;
+import java.io.OutputStream;
 import java.net.HttpURLConnection;
 import java.net.URL;
 import java.util.ArrayList;
@@ -107,11 +108,12 @@ public HttpResponse executeRequest(Request<?> request, Map<String, String> addit
             // Need to keep the connection open until the stream is consumed by the caller. Wrap the
             // stream such that close() will disconnect the connection.
             keepConnectionOpen = true;
+            int contentLength = connection.getContentLength ();
             return new HttpResponse(
                     responseCode,
                     convertHeaders(connection.getHeaderFields()),
                     connection.getContentLength(),
-                    new UrlConnectionInputStream(connection));
+                    createInputStream(request, connection, responseCode, contentLength));
         } finally {
             if (!keepConnectionOpen) {
                 connection.disconnect();
@@ -153,7 +155,7 @@ private static boolean hasResponseBody(int requestMethod, int responseCode) {
      * Wrapper for a {@link HttpURLConnection}'s InputStream which disconnects the connection on
      * stream close.
      */
-    static class UrlConnectionInputStream extends FilterInputStream {
+    private static class UrlConnectionInputStream extends FilterInputStream {
         private final HttpURLConnection mConnection;
 
         UrlConnectionInputStream(HttpURLConnection connection) {
@@ -168,10 +170,25 @@ public void close() throws IOException {
         }
     }
 
+    /**
+     * Overload this method for manipulate response stream (Use 'write (byte[] b, int off, int len)' in subclasse).
+     *
+     * @param request current request.
+     * @param connection current connection of request.
+     * @param responseCode response code.
+     * @param length size of response stream.
+     * @return an UrlConnectionInputStream object for read response.
+     */
+    protected FilterInputStream createInputStream (Request<?> request, HttpURLConnection connection,
+        int responseCode, int length) {
+
+        return new UrlConnectionInputStream (connection);
+    }
+
     /**
      * Initializes an {@link InputStream} from the given {@link HttpURLConnection}.
      *
-     * @param connection
+     * @param connection Request connection
      * @return an HttpEntity populated with data from <code>connection</code>.
      */
     private static InputStream inputStreamFromConnection(HttpURLConnection connection) {
@@ -223,7 +240,7 @@ private HttpURLConnection openConnection(URL url, Request<?> request) throws IOE
     // NOTE: Any request headers added here (via setRequestProperty or addRequestProperty) should be
     // checked against the existing properties in the connection and not overridden if already set.
     @SuppressWarnings("deprecation")
-    /* package */ static void setConnectionParametersForRequest(
+    /* package */ void setConnectionParametersForRequest(
             HttpURLConnection connection, Request<?> request) throws IOException, AuthFailureError {
         switch (request.getMethod()) {
             case Method.DEPRECATED_GET_OR_POST:
@@ -270,15 +287,15 @@ private HttpURLConnection openConnection(URL url, Request<?> request) throws IOE
         }
     }
 
-    private static void addBodyIfExists(HttpURLConnection connection, Request<?> request)
+    private void addBodyIfExists(HttpURLConnection connection, Request<?> request)
             throws IOException, AuthFailureError {
         byte[] body = request.getBody();
         if (body != null) {
             addBody(connection, request, body);
         }
     }
 
-    private static void addBody(HttpURLConnection connection, Request<?> request, byte[] body)
+    private void addBody(HttpURLConnection connection, Request<?> request, byte[] body)
             throws IOException {
         // Prepare output. There is no need to set Content-Length explicitly,
         // since this is handled by HttpURLConnection using the size of the prepared
@@ -289,8 +306,22 @@ private static void addBody(HttpURLConnection connection, Request<?> request, by
             connection.setRequestProperty(
                     HttpHeaderParser.HEADER_CONTENT_TYPE, request.getBodyContentType());
         }
-        DataOutputStream out = new DataOutputStream(connection.getOutputStream());
+        OutputStream out = this.createOutputStream ( request, connection, body.length );
         out.write(body);
-        out.close();
+        out.close ();
+    }
+
+    /**
+     * Overload this method for manipulate request stream (Use 'write (byte[] b)' in subclasse).
+     *
+     * @param request current request.
+     * @param connection current connection of request.
+     * @param length size of stream to write.
+     * @return an OutputStream object for write request body.
+     */
+    protected OutputStream createOutputStream (Request<?> request, HttpURLConnection connection,
+		int length) throws IOException {
+
+        return new DataOutputStream (connection.getOutputStream ());
     }
 }