InputStream test. Updated readme.

pom.xml

@@ -146,16 +146,22 @@
         <dependency>
             <groupId>com.dslplatform</groupId>
             <artifactId>dsl-json</artifactId>
-            <version>0.9.5</version>
+            <version>1.0.0</version>
         </dependency>
 
         <dependency>
             <groupId>com.dslplatform</groupId>
             <artifactId>dsl-json-processor</artifactId>
-            <version>0.4</version>
+            <version>1.0</version>
             <scope>provided</scope>
         </dependency>
 
+        <dependency>
+            <groupId>commons-io</groupId>
+            <artifactId>commons-io</artifactId>
+            <version>2.5</version>
+        </dependency>
+
     </dependencies>
 
     <build>

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadMapBoon.java

@@ -1,5 +1,6 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
@@ -26,6 +27,11 @@ public Map<?,?> _readItems(byte[] input) throws Exception {
         return mapper.readValue(input, Map.class);
     }
 
+    @Override
+    public Map<?,?> _readItems(InputStream input) throws Exception {
+        return mapper.readValue(input, Map.class);
+    }
+
     @Override
     public Map<?,?> _readItems(String input) throws Exception {
         return mapper.readValue(input, Map.class);

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadMapDslJson.java

@@ -0,0 +1,40 @@
+package com.cowtowncoder.jsonperf.dzone.read;
+
+import com.dslplatform.json.DslJson;
+import org.openjdk.jmh.annotations.OutputTimeUnit;
+import org.openjdk.jmh.annotations.Scope;
+import org.openjdk.jmh.annotations.State;
+
+import java.io.InputStream;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+@State(Scope.Thread)
+@OutputTimeUnit(TimeUnit.SECONDS)
+public class DZoneReadMapDslJson extends DZoneReadTestBase<Map<String, Object>>
+{
+    private final DslJson<Object> dsl;
+    private final byte[] buffer = new byte[8192];
+
+    public DZoneReadMapDslJson()
+    {
+        dsl = new DslJson<>();
+    }
+
+    @SuppressWarnings("unchecked")
+    @Override
+    public Map<String, Object> _readItems(byte[] input) throws Exception {
+        return dsl.deserialize(Map.class, input, input.length);
+    }
+
+    @SuppressWarnings("unchecked")
+    @Override
+    public Map<String, Object> _readItems(InputStream input) throws Exception {
+        return dsl.deserialize(Map.class, input, buffer);
+    }
+
+    @Override
+    public Map<String, Object> _readItems(String input) throws Exception {
+        return _readItems(input.getBytes("UTF-8"));
+    }
+}

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadMapFastjson.java

@@ -1,5 +1,6 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
@@ -25,6 +26,12 @@ public Map<Object,Object> _readItems(byte[] input) throws Exception {
         return (Map<Object,Object>) JSON.parse(input, Feature.DisableCircularReferenceDetect);
     }
 
+    @SuppressWarnings("unchecked")
+    @Override
+    public Map<Object,Object> _readItems(InputStream input) throws Exception {
+        return (Map<Object,Object>) JSON.parseObject(input, Map.class, Feature.DisableCircularReferenceDetect);
+    }
+
     @SuppressWarnings("unchecked")
     @Override
     public Map<Object,Object> _readItems(String input) throws Exception {

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadMapGSON.java

@@ -24,7 +24,12 @@ public DZoneReadMapGSON()
 
     @Override
     public Map<?,?> _readItems(byte[] input) throws Exception {
-        InputStreamReader r = new InputStreamReader(new ByteArrayInputStream(input), "UTF-8");
+        return _readItems(new ByteArrayInputStream(input));
+    }
+
+    @Override
+    public Map<?,?> _readItems(InputStream input) throws Exception {
+        InputStreamReader r = new InputStreamReader(input, "UTF-8");
         Map<?,?> value = gson.fromJson(r, Map.class);
         r.close();
         return value;

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadMapJackson.java

@@ -1,5 +1,6 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
@@ -26,6 +27,11 @@ public Map<Object,Object> _readItems(byte[] input) throws Exception {
         return objectReader.readValue(input);
     }
 
+    @Override
+    public Map<Object,Object> _readItems(InputStream input) throws Exception {
+        return objectReader.readValue(input);
+    }
+
     @Override
     public Map<Object,Object> _readItems(String input) throws Exception {
         return objectReader.readValue(input);

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadMapJacksonJr.java

@@ -1,5 +1,6 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
@@ -25,6 +26,11 @@ public Map<?,?> _readItems(byte[] input) throws Exception {
         return json.mapFrom(input);
     }
 
+    @Override
+    public Map<?,?> _readItems(InputStream input) throws Exception {
+        return json.mapFrom(input);
+    }
+
     @Override
     public Map<?,?> _readItems(String input) throws Exception {
         return json.mapFrom(input);

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadMapJohnzon.java

@@ -1,6 +1,7 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
 import java.io.ByteArrayInputStream;
+import java.io.InputStream;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
@@ -23,8 +24,13 @@ public DZoneReadMapJohnzon()
 
     @Override
     public Map<?,?> _readItems(byte[] input) throws Exception {
+        return _readItems(new ByteArrayInputStream(input));
+    }
+
+    @Override
+    public Map<?,?> _readItems(InputStream input) throws Exception {
         // force assign to ensure casting checks the type
-        Map<?,?> value = mapper.readObject(new ByteArrayInputStream(input), Object.class);
+        Map<?,?> value = mapper.readObject(input, Object.class);
         return value;
     }
 

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadMapJsonIO.java

@@ -18,7 +18,12 @@ public DZoneReadMapJsonIO() { }
 
     @Override
     public Map<?,?> _readItems(byte[] input) throws Exception {
-        JsonReader r = new JsonReader(new ByteArrayInputStream(input));
+        return _readItems(new ByteArrayInputStream(input));
+    }
+
+    @Override
+    public Map<?,?> _readItems(InputStream input) throws Exception {
+        JsonReader r = new JsonReader(input);
         Map<?,?> value = (Map<?,?>) r.readObject();
         r.close();
         return value;

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadMapJsonMoshi.java

@@ -1,8 +1,10 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
+import org.apache.commons.io.IOUtils;
 import org.openjdk.jmh.annotations.OutputTimeUnit;
 import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.State;
@@ -30,6 +32,11 @@ public Map _readItems(byte[] input) throws Exception {
         return adapter.fromJson(new String(input, "UTF-8"));
     }
 
+    @Override
+    public Map _readItems(InputStream input) throws Exception {
+        return adapter.fromJson(IOUtils.toString(input, "UTF-8"));
+    }
+
     @Override
     public Map _readItems(String input) throws Exception {
         return adapter.fromJson(input);

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadMapJsonParse.java

@@ -1,8 +1,10 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
+import org.apache.commons.io.IOUtils;
 import org.openjdk.jmh.annotations.OutputTimeUnit;
 import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.State;
@@ -27,6 +29,11 @@ public Map<?,?> _readItems(byte[] input) throws Exception {
         return _readItems(new String(input, "UTF-8"));
     }
 
+    @Override
+    public Map<?,?> _readItems(InputStream input) throws Exception {
+        return _readItems(IOUtils.toString(input, "UTF-8"));
+    }
+
     @Override
     public Map<?,?> _readItems(String input) throws Exception {
         return parse.map(input);

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadPojoBoon.java

@@ -1,5 +1,6 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.concurrent.TimeUnit;
 
 import org.openjdk.jmh.annotations.OutputTimeUnit;
@@ -27,6 +28,11 @@ public MeasurementPOJO _readItems(byte[] input) throws Exception {
         return mapper.readValue(input, MeasurementPOJO.class);
     }
 
+    @Override
+    public MeasurementPOJO _readItems(InputStream input) throws Exception {
+        return mapper.readValue(input, MeasurementPOJO.class);
+    }
+
     @Override
     public MeasurementPOJO _readItems(String input) throws Exception {
         return mapper.readValue(input, MeasurementPOJO.class);

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadPojoDslJson.java

@@ -6,13 +6,15 @@
 import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.State;
 
+import java.io.InputStream;
 import java.util.concurrent.TimeUnit;
 
 @State(Scope.Thread)
 @OutputTimeUnit(TimeUnit.SECONDS)
 public class DZoneReadPojoDslJson extends DZoneReadTestBase<MeasurementPOJO>
 {
     private final DslJson<Object> dsl;
+    private final byte[] buffer = new byte[8192];
 
     public DZoneReadPojoDslJson()
     {
@@ -24,6 +26,11 @@ public MeasurementPOJO _readItems(byte[] input) throws Exception {
         return dsl.deserialize(MeasurementPOJO.class, input, input.length);
     }
 
+    @Override
+    public MeasurementPOJO _readItems(InputStream input) throws Exception {
+        return dsl.deserialize(MeasurementPOJO.class, input, buffer);
+    }
+
     @Override
     public MeasurementPOJO _readItems(String input) throws Exception {
         return _readItems(input.getBytes("UTF-8"));

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadPojoFastjson.java

@@ -1,5 +1,6 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.concurrent.TimeUnit;
 
 import org.openjdk.jmh.annotations.OutputTimeUnit;
@@ -24,6 +25,11 @@ public MeasurementPOJO _readItems(byte[] input) throws Exception {
         return JSON.parseObject(input, MeasurementPOJO.class, Feature.DisableCircularReferenceDetect);
     }
 
+    @Override
+    public MeasurementPOJO _readItems(InputStream input) throws Exception {
+        return JSON.parseObject(input, MeasurementPOJO.class, Feature.DisableCircularReferenceDetect);
+    }
+
     @Override
     public MeasurementPOJO _readItems(String input) throws Exception {
         return JSON.parseObject(input, MeasurementPOJO.class, Feature.DisableCircularReferenceDetect);

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadPojoGSON.java

@@ -24,7 +24,12 @@ public DZoneReadPojoGSON()
 
     @Override
     public MeasurementPOJO _readItems(byte[] input) throws Exception {
-        InputStreamReader r = new InputStreamReader(new ByteArrayInputStream(input), "UTF-8");
+        return _readItems(new ByteArrayInputStream(input));
+    }
+
+    @Override
+    public MeasurementPOJO _readItems(InputStream input) throws Exception {
+        InputStreamReader r = new InputStreamReader(input, "UTF-8");
         MeasurementPOJO value = gson.fromJson(r, MeasurementPOJO.class);
         r.close();
         return value;

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadPojoJackson.java

@@ -1,5 +1,6 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.concurrent.TimeUnit;
 
 import org.openjdk.jmh.annotations.OutputTimeUnit;
@@ -26,6 +27,11 @@ public MeasurementPOJO _readItems(byte[] input) throws Exception {
         return objectReader.readValue(input);
     }
 
+    @Override
+    public MeasurementPOJO _readItems(InputStream input) throws Exception {
+        return objectReader.readValue(input);
+    }
+
     @Override
     public MeasurementPOJO _readItems(String input) throws Exception {
         return objectReader.readValue(input);

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadPojoJacksonAB.java

@@ -1,5 +1,6 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.concurrent.TimeUnit;
 
 import org.openjdk.jmh.annotations.OutputTimeUnit;
@@ -29,6 +30,11 @@ public MeasurementPOJO _readItems(byte[] input) throws Exception {
         return objectReader.readValue(input);
     }
 
+    @Override
+    public MeasurementPOJO _readItems(InputStream input) throws Exception {
+        return objectReader.readValue(input);
+    }
+
     @Override
     public MeasurementPOJO _readItems(String input) throws Exception {
         return objectReader.readValue(input);

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadPojoJacksonJr.java

@@ -1,5 +1,6 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
+import java.io.InputStream;
 import java.util.concurrent.TimeUnit;
 
 import org.openjdk.jmh.annotations.OutputTimeUnit;
@@ -25,6 +26,11 @@ public MeasurementPOJO _readItems(byte[] input) throws Exception {
         return json.beanFrom(MeasurementPOJO.class, input);
     }
 
+    @Override
+    public MeasurementPOJO _readItems(InputStream input) throws Exception {
+        return json.beanFrom(MeasurementPOJO.class, input);
+    }
+
     @Override
     public MeasurementPOJO _readItems(String input) throws Exception {
         return json.beanFrom(MeasurementPOJO.class, input);

src/main/java/com/cowtowncoder/jsonperf/dzone/read/DZoneReadPojoJohnzon.java

@@ -1,6 +1,7 @@
 package com.cowtowncoder.jsonperf.dzone.read;
 
 import java.io.ByteArrayInputStream;
+import java.io.InputStream;
 import java.util.concurrent.TimeUnit;
 
 import org.apache.johnzon.mapper.Mapper;
@@ -27,6 +28,11 @@ public MeasurementPOJO _readItems(byte[] input) throws Exception {
         return mapper.readObject(new ByteArrayInputStream(input), MeasurementPOJO.class);
     }
 
+    @Override
+    public MeasurementPOJO _readItems(InputStream input) throws Exception {
+        return mapper.readObject(input, MeasurementPOJO.class);
+    }
+
     @Override
     public MeasurementPOJO _readItems(String input) throws Exception {
         return mapper.readObject(input, MeasurementPOJO.class);