Changes for AsyncHttpClient#230.

Author: rlubke

api/src/main/java/com/ning/http/client/consumers/AppendableBodyConsumer.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2010-2012 Sonatype, Inc. All rights reserved.
+ * Copyright (c) 2010-2013 Sonatype, Inc. All rights reserved.
  *
  * This program is licensed to you under the Apache License Version 2.0,
  * and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -41,7 +41,10 @@ public AppendableBodyConsumer(Appendable appendable) {
      */
     /* @Override */
     public void consume(ByteBuffer byteBuffer) throws IOException {
-        appendable.append(new String(byteBuffer.array(), byteBuffer.arrayOffset(), byteBuffer.remaining(), encoding));
+        appendable.append(new String(byteBuffer.array(),
+                                     byteBuffer.arrayOffset() + byteBuffer.position(),
+                                     byteBuffer.remaining(),
+                                     encoding));
     }
 
     /**

api/src/main/java/com/ning/http/client/consumers/FileBodyConsumer.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2010-2012 Sonatype, Inc. All rights reserved.
+ * Copyright (c) 2010-2013 Sonatype, Inc. All rights reserved.
  *
  * This program is licensed to you under the Apache License Version 2.0,
  * and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -35,7 +35,9 @@ public FileBodyConsumer(RandomAccessFile file) {
     /* @Override */
     public void consume(ByteBuffer byteBuffer) throws IOException {
         // TODO: Channel.transferFrom may be a good idea to investigate.
-        file.write(byteBuffer.array());
+        file.write(byteBuffer.array(),
+                   byteBuffer.arrayOffset() + byteBuffer.position(),
+                   byteBuffer.remaining());
     }
 
     /**

api/src/main/java/com/ning/http/client/consumers/OutputStreamBodyConsumer.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2010-2012 Sonatype, Inc. All rights reserved.
+ * Copyright (c) 2010-2013 Sonatype, Inc. All rights reserved.
  *
  * This program is licensed to you under the Apache License Version 2.0,
  * and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -34,7 +34,9 @@ public OutputStreamBodyConsumer(OutputStream outputStream) {
      */
     /* @Override */
     public void consume(ByteBuffer byteBuffer) throws IOException {
-        outputStream.write(byteBuffer.array(), byteBuffer.arrayOffset(), byteBuffer.remaining());
+        outputStream.write(byteBuffer.array(),
+                           byteBuffer.arrayOffset() + byteBuffer.position(),
+                           byteBuffer.remaining());
     }
 
     /**