feat: pipe stream on fs write (#206)

* pipe allloewd on write stream * code readable * fix: 'if' statment missed curly braces * Update src/commands/registration/stor.js Replacing write data with pipe on STOR command Co-authored-by: Tyler Stewart <[email protected]> * fix: socket on data replaced with socket on pipe * fix: extra space Co-authored-by: Tyler Stewart <[email protected]> Co-authored-by: Tyler Stewart <[email protected]>
QuorumDMS · Aug 25, 2020 · 05a68cf · 05a68cf
1 parent 31290fc
commit 05a68cf
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/src/commands/registration/stor.js b/src/commands/registration/stor.js
@@ -37,12 +37,7 @@ module.exports = {
       });
 
       const socketPromise = new Promise((resolve, reject) => {
-        this.connector.socket.on('data', (data) => {
-          if (this.connector.socket) this.connector.socket.pause();
-          if (stream && stream.writable) {
-            stream.write(data, () => this.connector.socket && this.connector.socket.resume());
-          }
-        });
+        this.connector.socket.pipe(stream, {end: false});
         this.connector.socket.once('end', () => {
           if (stream.listenerCount('close')) stream.emit('close');
           else stream.end();