Add support for InputStream and tests for sending byte[] as List<Short>

Author: mythz

src/AndroidClient/client/src/main/java/net/servicestack/client/JsonServiceClient.java

@@ -317,9 +317,10 @@ public <TResponse> TResponse send(String url, String httpMethod, Object request,
 
     public <TResponse> TResponse send(String requestUrl, String httpMethod, byte[] requestBody, String requestType, Object responseClass) {
         HttpURLConnection req = null;
+        Class resClass = null;
         try {
             req = createRequest(requestUrl, httpMethod, requestBody, requestType);
-            Class resClass = responseClass instanceof Class ? (Class)responseClass : null;
+            resClass = responseClass instanceof Class ? (Class)responseClass : null;
             Type resType = responseClass instanceof Type ? (Type)responseClass : null;
             if (resClass == null && resType == null)
                 throw new RuntimeException("responseClass '" + responseClass.getClass().getSimpleName() + "' must be a Class or Type");
@@ -364,6 +365,8 @@ public <TResponse> TResponse send(String requestUrl, String httpMethod, byte[] r
                 return (TResponse)Utils.readBytesToEnd(req);
             if (resClass == String.class)
                 return (TResponse)Utils.readToEnd(is, UTF8.name());
+            if (resClass == InputStream.class)
+                return (TResponse)is;
 
             if (Log.isDebugEnabled()) {
                 String json = Utils.readToEnd(is, UTF8.name());
@@ -388,7 +391,7 @@ public <TResponse> TResponse send(String requestUrl, String httpMethod, byte[] r
             throw new RuntimeException(e);
         }
         finally {
-            if (req != null)
+            if (req != null && resClass != InputStream.class)
                 req.disconnect();
         }
     }

src/AndroidClient/client/src/test/java/net/servicestack/client/tests/TestServiceTests.java

@@ -7,6 +7,8 @@
 import net.servicestack.client.*;
 import net.servicestack.client.tests.testdtos.*;
 
+import java.io.IOException;
+import java.io.InputStream;
 import java.math.BigDecimal;
 import java.math.BigInteger;
 import java.net.HttpURLConnection;
@@ -283,6 +285,27 @@ public void test_Can_get_response_as_Raw_Bytes() {
         assertEquals("World", Utils.fromUtf8Bytes(response));
     }
 
+    public void test_Can_get_response_as_Stream() throws IOException {
+        InputStream is = client.get("/json/reply/HelloString?Name=World", InputStream.class);
+        byte[] response = Utils.readBytesToEnd(is);
+        is.close();
+        assertEquals("World", Utils.fromUtf8Bytes(response));
+    }
+
+    public void test_Can_post_data_and_read_as_Stream() throws IOException {
+        ReturnStream req = new ReturnStream();
+        ArrayList<Short> data = new ArrayList<>();
+        data.add((short) 65);
+        data.add((short) 66);
+        data.add((short) 67);
+        req.setData(data);
+
+        InputStream is = client.post(req);
+        byte[] response = Utils.readBytesToEnd(is);
+        is.close();
+        assertEquals("ABC", Utils.fromUtf8Bytes(response));
+    }
+
     /* TEST HELPERS */
 
     public static HelloAllTypes createHelloAllTypes(){