[utils/createReplaceStream] trim the buffer based on the length of to…

…Replace, not replacement
elastic · Oct 3, 2017 · 8ca1c33 · 8ca1c33
1 parent e0be3b8
commit 8ca1c33
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/utils/streams/replace_stream.js b/src/utils/streams/replace_stream.js
@@ -23,9 +23,9 @@ export function createReplaceStream(toReplace, replacement) {
           buffer = buffer.slice(index + toReplace.length);
         }
 
-        if (buffer.length > replacement.length) {
-          this.push(buffer.slice(0, buffer.length - replacement.length));
-          buffer = buffer.slice(-replacement.length);
+        if (buffer.length > toReplace.length) {
+          this.push(buffer.slice(0, buffer.length - toReplace.length));
+          buffer = buffer.slice(-toReplace.length);
         }
 
         done();