perf: use FastBuffer

nodejs · Feb 3, 2023 · aa4d14a · aa4d14a
1 parent ce3d4ce
commit aa4d14a
Showing 1 changed file with 5 additions and 8 deletions.
diff --git a/lib/client.js b/lib/client.js
@@ -65,6 +65,7 @@ const {
   kLocalAddress,
   kMaxResponseSize
 } = require('./core/symbols')
+const FastBuffer = Buffer[Symbol.species]
 
 const kClosedResolve = Symbol('kClosedResolve')
 
@@ -363,8 +364,7 @@ async function lazyllhttp () {
       wasm_on_status: (p, at, len) => {
         assert.strictEqual(currentParser.ptr, p)
         const start = at - currentBufferPtr
-        const end = start + len
-        return currentParser.onStatus(currentBufferRef.slice(start, end)) || 0
+        return currentParser.onStatus(new FastBuffer(currentBufferRef.buffer, start, len)) || 0
       },
       wasm_on_message_begin: (p) => {
         assert.strictEqual(currentParser.ptr, p)
@@ -373,14 +373,12 @@ async function lazyllhttp () {
       wasm_on_header_field: (p, at, len) => {
         assert.strictEqual(currentParser.ptr, p)
         const start = at - currentBufferPtr
-        const end = start + len
-        return currentParser.onHeaderField(currentBufferRef.slice(start, end)) || 0
+        return currentParser.onHeaderField(new FastBuffer(currentBufferRef.buffer, start, len)) || 0
       },
       wasm_on_header_value: (p, at, len) => {
         assert.strictEqual(currentParser.ptr, p)
         const start = at - currentBufferPtr
-        const end = start + len
-        return currentParser.onHeaderValue(currentBufferRef.slice(start, end)) || 0
+        return currentParser.onHeaderValue(new FastBuffer(currentBufferRef.buffer, start, len)) || 0
       },
       wasm_on_headers_complete: (p, statusCode, upgrade, shouldKeepAlive) => {
         assert.strictEqual(currentParser.ptr, p)
@@ -389,8 +387,7 @@ async function lazyllhttp () {
       wasm_on_body: (p, at, len) => {
         assert.strictEqual(currentParser.ptr, p)
         const start = at - currentBufferPtr
-        const end = start + len
-        return currentParser.onBody(currentBufferRef.slice(start, end)) || 0
+        return currentParser.onBody(new FastBuffer(currentBufferRef.buffer, start, len)) || 0
       },
       wasm_on_message_complete: (p) => {
         assert.strictEqual(currentParser.ptr, p)