feat: support reading from the request stream (#67)

googleapis · Aug 7, 2019 · ae23054 · ae23054
1 parent 12901a0
commit ae23054
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 4 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -269,10 +269,12 @@ function teenyRequest(
     options.compress = false;
     fetch(uri, options).then(
       res => {
-        res.body.on('error', err => {
-          console.log('whoa there was an error, passing it on: ' + err);
-          requestStream.emit('error', err);
-        });
+        res.body
+          .on('error', err => {
+            console.log('whoa there was an error, passing it on: ' + err);
+            requestStream.emit('error', err);
+          })
+          .pipe(requestStream);
 
         const response = fetchToRequestResponse(options, res);
         requestStream.emit('response', response);

diff --git a/test/index.ts b/test/index.ts
@@ -172,4 +172,15 @@ describe('teeny', () => {
       return done();
     });
   });
+
+  it('should provide a readable stream', done => {
+    const scope = mockJson();
+    teenyRequest({uri})
+      .on('error', done)
+      .on('data', data => {
+        const json = JSON.parse(data.toString());
+        assert.deepStrictEqual(json, {hello: '🌍'});
+        done();
+      });
+  });
 });