enable chunked response

Author: marcoow

src/index.js

@@ -32,28 +32,33 @@ function fastbootExpressMiddleware(distPath, options) {
       .then(success, failure);
 
     function success(result) {
-      result.html()
-        .then(html => {
-          let headers = result.headers;
-          let statusMessage = result.error ? 'NOT OK ' : 'OK ';
-
-          for (var pair of headers.entries()) {
-            res.set(pair[0], pair[1]);
-          }
-
-          if (result.error) {
-            log("RESILIENT MODE CAUGHT:", result.error.stack);
-            next(result.error);
-          }
-
-          log(result.statusCode, statusMessage + path);
-          res.status(result.statusCode);
-          res.send(html);
-        })
-        .catch(error => {
-          res.status(500);
-          next(error);
-        });
+        result.chunks()
+          .then(chunks => {
+            let headers = result.headers;
+            let statusMessage = result.error ? 'NOT OK ' : 'OK ';
+        
+            for (var pair of headers.entries()) {
+              res.set(pair[0], pair[1]);
+            }
+        
+            if (result.error) {
+              log("RESILIENT MODE CAUGHT:", result.error.stack);
+              next(result.error);
+            }
+        
+            log(result.statusCode, statusMessage + path);
+            res.status(result.statusCode);
+            if (result.error) {
+              res.send(chunks[0]);
+            } else {
+              chunks.forEach(chunk => res.write(chunk));
+              res.end();
+            }
+          })
+          .catch(error => {
+            res.status(500);
+            next(error);
+          });
     }
 
     function failure(error) {

test/middleware-test.js

@@ -51,6 +51,20 @@ describe("FastBoot", function() {
       });
   });
 
+  it("responds with a chunked response", function() {
+    let middleware = fastbootMiddleware({
+      distPath: fixture('basic-app')
+    });
+    server = new TestHTTPServer(middleware, { errorHandling: true });
+
+    return server.start()
+      .then(() => server.request('/', { resolveWithFullResponse: true }))
+      .then(({ body, _, headers }) => {
+        expect(headers['transfer-encoding']).to.eq('chunked');
+        expect(body).to.match(/Welcome to Ember/);
+      });
+  });
+
   it("returns 404 when navigating to a URL that doesn't exist", function() {
     let middleware = fastbootMiddleware(fixture('basic-app'));
     server = new TestHTTPServer(middleware);