use buffered output stream

2 files changed, 21 insertions, 41 deletions

diff --git a/AndroidAsync/src/com/koushikdutta/async/http/AsyncHttpClient.java b/AndroidAsync/src/com/koushikdutta/async/http/AsyncHttpClient.java
index dac5d30..5c8615b 100644
--- a/AndroidAsync/src/com/koushikdutta/async/http/AsyncHttpClient.java
+++ b/AndroidAsync/src/com/koushikdutta/async/http/AsyncHttpClient.java
@@ -1,30 +1,7 @@
 package com.koushikdutta.async.http;
 
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.net.HttpURLConnection;
-import java.net.URI;
-import java.nio.ByteBuffer;
-import java.util.ArrayList;
-import java.util.concurrent.CancellationException;
-import java.util.concurrent.TimeoutException;
-
-import junit.framework.Assert;
-
-import org.json.JSONException;
-import org.json.JSONObject;
-
 import android.os.Handler;
-
-import com.koushikdutta.async.AsyncSSLException;
-import com.koushikdutta.async.AsyncServer;
-import com.koushikdutta.async.AsyncSocket;
-import com.koushikdutta.async.ByteBufferList;
-import com.koushikdutta.async.DataEmitter;
-import com.koushikdutta.async.DataSink;
-import com.koushikdutta.async.NullDataCallback;
+import com.koushikdutta.async.*;
 import com.koushikdutta.async.callback.CompletedCallback;
 import com.koushikdutta.async.callback.ConnectCallback;
 import com.koushikdutta.async.callback.DataCallback;
@@ -36,6 +13,16 @@ import com.koushikdutta.async.future.SimpleFuture;
 import com.koushikdutta.async.http.AsyncHttpClientMiddleware.OnRequestCompleteData;
 import com.koushikdutta.async.http.libcore.RawHeaders;
 import com.koushikdutta.async.stream.OutputStreamDataCallback;
+import junit.framework.Assert;
+import org.json.JSONException;
+import org.json.JSONObject;
+
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.URI;
+import java.nio.ByteBuffer;
+import java.util.ArrayList;
+import java.util.concurrent.TimeoutException;
 
 public class AsyncHttpClient {
     private static AsyncHttpClient mDefaultInstance;
@@ -393,9 +380,9 @@ public class AsyncHttpClient {
         };
         ret.setParent(cancel);
         file.getParentFile().mkdirs();
-        final FileOutputStream fout;
+        final OutputStream fout;
         try {
-            fout = new FileOutputStream(file);
+            fout = new BufferedOutputStream(new FileOutputStream(file), 8192);
         }
         catch (FileNotFoundException e) {
             if (ret.setComplete(e))
diff --git a/AndroidAsyncTest/src/com/koushikdutta/async/test/MultipartTests.java b/AndroidAsyncTest/src/com/koushikdutta/async/test/MultipartTests.java
index d2a7725..81f537b 100644
--- a/AndroidAsyncTest/src/com/koushikdutta/async/test/MultipartTests.java
+++ b/AndroidAsyncTest/src/com/koushikdutta/async/test/MultipartTests.java
@@ -1,29 +1,23 @@
 package com.koushikdutta.async.test;
 
-import java.io.File;
-import java.io.FileOutputStream;
-import java.util.concurrent.TimeUnit;
-
-import junit.framework.TestCase;
 import android.os.Environment;
-
 import com.koushikdutta.async.AsyncServer;
 import com.koushikdutta.async.ByteBufferList;
 import com.koushikdutta.async.DataEmitter;
 import com.koushikdutta.async.callback.CompletedCallback;
 import com.koushikdutta.async.callback.DataCallback;
 import com.koushikdutta.async.future.Future;
-import com.koushikdutta.async.http.AsyncHttpClient;
+import com.koushikdutta.async.http.*;
 import com.koushikdutta.async.http.AsyncHttpClient.StringCallback;
-import com.koushikdutta.async.http.AsyncHttpPost;
-import com.koushikdutta.async.http.AsyncHttpResponse;
-import com.koushikdutta.async.http.MultipartCallback;
-import com.koushikdutta.async.http.MultipartFormDataBody;
-import com.koushikdutta.async.http.Part;
 import com.koushikdutta.async.http.server.AsyncHttpServer;
 import com.koushikdutta.async.http.server.AsyncHttpServerRequest;
 import com.koushikdutta.async.http.server.AsyncHttpServerResponse;
 import com.koushikdutta.async.http.server.HttpServerRequestCallback;
+import junit.framework.TestCase;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.util.concurrent.TimeUnit;
 
 public class MultipartTests extends TestCase {
     AsyncHttpServer httpServer;
@@ -64,7 +58,7 @@ public class MultipartTests extends TestCase {
                         }
                     }
                 });
-                
+
                 request.setEndCallback(new CompletedCallback() {
                     @Override
                     public void onCompleted(Exception ex) {
@@ -74,8 +68,7 @@ public class MultipartTests extends TestCase {
             }
         });
     }
-    
-    
+
     @Override
     protected void tearDown() throws Exception {
         super.tearDown();