Marcin K 78a14a164d
feat(): pg-query-stream typescript (#2376)
* feat(): start converting pg-query stream

* feat(): solution project, initial version of typescript-pg-query stream

* chore(): mocha with typescript

* fix(): eslint ignore query stream dist

* refactor(pg-query-stream): convert test to ts

* chore(): fixed type errors

* chore(): fix helper usage

* chore(): use ts-node compatibile with node v8

* fix(): addd es extension

* chore(): remove emitClose and added compilation for async iterators

* chore(): condition for asyc iteration test

* chore(): rename class to match ts-defs

* chore(): tests to import from src instead of dist

* chore(): remove prettier from peer deps:

* chore(): update lock file
2020-11-03 11:17:49 -06:00

18 lines
419 B
TypeScript

import helper from './helper'
import assert from 'assert'
import concat from 'concat-stream'
import QueryStream from '../src'
helper('instant', function (client) {
it('instant', function (done) {
const query = new QueryStream('SELECT pg_sleep(1)', [])
const stream = client.query(query)
stream.pipe(
concat(function (res) {
assert.equal(res.length, 1)
done()
})
)
})
})