Actually fix a really minor bug in body read function (#121)

src/HTTPure/Body.js

@@ -1,17 +0,0 @@
-/* global exports */
-
-"use strict";
-
-exports.aggregateChunks = function (stream) {
-  return function(onEnd) {
-    return function() {
-      var chunks = [];
-      stream.on("data", function (chunk) {
-        chunks.push(chunk);
-      });
-      stream.on("end", function() {
-        onEnd(chunks)();
-      });
-    };
-  }
-};

src/HTTPure/Body.purs

@@ -8,9 +8,9 @@ module HTTPure.Body
 import Prelude
 
 import Data.Either as Either
-import Data.Foldable as Foldable
 import Effect as Effect
 import Effect.Aff as Aff
+import Effect.Ref as Ref
 import HTTPure.Headers as Headers
 import Node.Buffer as Buffer
 import Node.Encoding as Encoding
@@ -78,26 +78,12 @@ instance bodyChunked ::
     Stream.onEnd stream $ done $ Either.Right unit
     pure Aff.nonCanceler
 
--- | Given a readable stream accumulates incomming chunks preserving
--- | their original order.
--- |
--- | We want to append every chunk using single function call
--- | to ensure "atomicity" of this action. If we use any additional
--- | function calls inside our data handler Javascript scheduler can interleave
--- | processing of multiple chunks and we can't be sure if they end up
--- | in correct order.
--- |
--- | Please refer to #117 for more details.
-foreign import aggregateChunks :: forall w. Stream.Readable w ->
-                                  (Array Buffer.Buffer -> Effect.Effect Unit) ->
-                                  Effect.Effect Unit
-
 -- | Extract the contents of the body of the HTTP `Request`.
 read :: HTTP.Request -> Aff.Aff String
 read request = Aff.makeAff \done -> do
-  let
+  let stream = HTTP.requestAsStream request
-    stream = HTTP.requestAsStream request
+  buf <- Ref.new ""
-    decode = Buffer.toString Encoding.UTF8
+  Stream.onDataString stream Encoding.UTF8 \str ->
-  aggregateChunks stream $
+    void $ Ref.modify (_ <> str) buf
-    Foldable.foldMap decode >=> Either.Right >>> pure >=> done
+  Stream.onEnd stream $ Ref.read buf >>= Either.Right >>> done
   pure Aff.nonCanceler