android/okhttp
1
0
Fork 0
mirror of https://github.com/square/okhttp.git synced 2026-01-18 20:40:58 +03:00
Code Releases Activity

Merge pull request #1499 from square/jwilson_0314_stream_okcurl

Browse Source 
Stream the response in okcurl.
This commit is contained in:
Adrian Cole
2015-03-14 20:34:59 -07:00
parent 548bd196de e90fecef86
commit fcaa762e40
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
okcurl/src/main/java/com/squareup/okhttp/curl/Main.java
View File

@@ -49,7 +49,9 @@ import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
import okio.BufferedSource;
import okio.Okio;
import okio.Sink;
import static java.util.concurrent.TimeUnit.SECONDS;
@@ -151,9 +153,15 @@ public class Main extends HelpOption implements Runnable {
System.out.println();
}
response.body().source().readAll(Okio.sink(System.out));
// Stream the response to the System.out as it is returned from the server.
Sink out = Okio.sink(System.out);
BufferedSource source = response.body().source();
while (!source.exhausted()) {
out.write(source.buffer(), source.buffer().size());
out.flush();
}
response.body().close();
System.out.flush();
} catch (IOException e) {
e.printStackTrace();
} finally {