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`]
 })