Fix deno partial writes

,,

Author: porsager

cjs/tests/index.js

@@ -784,8 +784,8 @@ t('has server parameters', async() => {
 
 t('big query body', async() => {
   await sql`create table test (x int)`
-  return [1000, (await sql`insert into test ${
-    sql([...Array(1000).keys()].map(x => ({ x })))
+  return [50000, (await sql`insert into test ${
+    sql([...Array(50000).keys()].map(x => ({ x })))
   }`).count, await sql`drop table test`]
 })
 

deno/polyfills.js

@@ -69,12 +69,14 @@ export const net = {
         socket.events[x] = socket.events[x].filter(x => x !== fn && x.once !== fn)
       },
       write: (x, cb) => {
-        socket.raw.write(x)
-          .then(() => (cb && cb(null)))
-          .catch(err => {
-            cb && cb()
-            call(socket.events.error, err)
-          })
+        socket.raw.write(x).then(l => {
+          l < x.length
+            ? socket.write(x.slice(l), cb)
+            : (cb && cb(null))
+        }).catch(err => {
+          cb && cb()
+          call(socket.events.error, err)
+        })
         return false
       },
       destroy: () => close(),

deno/tests/index.js

@@ -786,8 +786,8 @@ t('has server parameters', async() => {
 
 t('big query body', async() => {
   await sql`create table test (x int)`
-  return [1000, (await sql`insert into test ${
-    sql([...Array(1000).keys()].map(x => ({ x })))
+  return [50000, (await sql`insert into test ${
+    sql([...Array(50000).keys()].map(x => ({ x })))
   }`).count, await sql`drop table test`]
 })
 

tests/index.js

@@ -784,8 +784,8 @@ t('has server parameters', async() => {
 
 t('big query body', async() => {
   await sql`create table test (x int)`
-  return [1000, (await sql`insert into test ${
-    sql([...Array(1000).keys()].map(x => ({ x })))
+  return [50000, (await sql`insert into test ${
+    sql([...Array(50000).keys()].map(x => ({ x })))
   }`).count, await sql`drop table test`]
 })