Use subarray instead of slice

Author: porsager

src/bytes.js

@@ -47,13 +47,13 @@ const b = Object.assign(reset, messages, {
     return b
   },
   raw(x) {
-    buffer = Buffer.concat([buffer.slice(0, b.i), x])
+    buffer = Buffer.concat([buffer.subarray(0, b.i), x])
     b.i = buffer.length
     return b
   },
   end(at = 1) {
     buffer.writeUInt32BE(b.i - at, at)
-    const out = buffer.slice(0, b.i)
+    const out = buffer.subarray(0, b.i)
     b.i = 0
     buffer = Buffer.allocUnsafe(size)
     return out

src/connection.js

@@ -309,12 +309,12 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
       }
 
       try {
-        handle(incoming.slice(0, length + 1))
+        handle(incoming.subarray(0, length + 1))
       } catch (e) {
         query && (query.cursorFn || query.describeFirst) && write(Sync)
         errored(e)
       }
-      incoming = incoming.slice(length + 1)
+      incoming = incoming.subarray(length + 1)
       remaining = 0
       incomings = null
     }
@@ -483,7 +483,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
       value = length === -1
         ? null
         : query.isRaw === true
-          ? x.slice(index, index += length)
+          ? x.subarray(index, index += length)
           : column.parser === undefined
             ? x.toString('utf8', index, index += length)
             : column.parser.array === true
@@ -652,7 +652,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
 
   async function AuthenticationMD5Password(x) {
     write(
-      b().p().str('md5' + md5(Buffer.concat([Buffer.from(md5((await Pass()) + user)), x.slice(9)]))).z(1).end()
+      b().p().str('md5' + md5(Buffer.concat([Buffer.from(md5((await Pass()) + user)), x.subarray(9)]))).z(1).end()
     )
   }
 
@@ -851,7 +851,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   }
 
   function CopyData(x) {
-    stream.push(x.slice(5)) || socket.pause()
+    stream.push(x.subarray(5)) || socket.pause()
   }
 
   function CopyDone() {

src/subscribe.js

@@ -103,7 +103,7 @@ export default function Subscribe(postgres, options) {
 
     function data(x) {
       if (x[0] === 0x77)
-        parse(x.slice(25), state, sql.options.parsers, handle)
+        parse(x.subarray(25), state, sql.options.parsers, handle)
       else if (x[0] === 0x6b && x[17])
         pong()
     }
@@ -143,8 +143,8 @@ function parse(x, state, parsers, handle) {
     R: x => {  // Relation
       let i = 1
       const r = state[x.readUInt32BE(i)] = {
-        schema: String(x.slice(i += 4, i = x.indexOf(0, i))) || 'pg_catalog',
-        table: String(x.slice(i + 1, i = x.indexOf(0, i + 1))),
+        schema: String(x.subarray(i += 4, i = x.indexOf(0, i))) || 'pg_catalog',
+        table: String(x.subarray(i + 1, i = x.indexOf(0, i + 1))),
         columns: Array(x.readUInt16BE(i += 2)),
         keys: []
       }
@@ -156,7 +156,7 @@ function parse(x, state, parsers, handle) {
       while (i < x.length) {
         column = r.columns[columnIndex++] = {
           key: x[i++],
-          name: String(x.slice(i, i = x.indexOf(0, i))),
+          name: String(x.subarray(i, i = x.indexOf(0, i))),
           type: x.readUInt32BE(i += 1),
           parser: parsers[x.readUInt32BE(i)],
           atttypmod: x.readUInt32BE(i += 4)
@@ -170,7 +170,7 @@ function parse(x, state, parsers, handle) {
     O: () => { /* noop */ }, // Origin
     B: x => { // Begin
       state.date = Time(x.readBigInt64BE(9))
-      state.lsn = x.slice(1, 9)
+      state.lsn = x.subarray(1, 9)
     },
     I: x => { // Insert
       let i = 1