Skip to content

Commit 1200da5

Browse files
committed
Fix test
1 parent 0a10525 commit 1200da5

File tree

2 files changed

+1810
-3
lines changed

2 files changed

+1810
-3
lines changed

index.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ var nextUniqueID = 1 // concept borrowed from org.postgresql.core.v3.QueryExecut
99
function Cursor (text, values, config) {
1010
EventEmitter.call(this)
1111

12-
this._conf = config || { }
12+
this._conf = config || {}
1313
this.text = text
1414
this.values = values ? values.map(prepare) : null
1515
this.connection = null
@@ -148,15 +148,15 @@ Cursor.prototype.end = function (cb) {
148148
if (this.state !== 'initialized') {
149149
this.connection.sync()
150150
}
151-
this.connection.stream.once('end', cb)
151+
this.connection.once('end', cb)
152152
this.connection.end()
153153
}
154154

155155
Cursor.prototype.close = function (cb) {
156156
if (this.state === 'done') {
157157
return setImmediate(cb)
158158
}
159-
this.connection.close({type: 'P'})
159+
this.connection.close({ type: 'P' })
160160
this.connection.sync()
161161
this.state = 'done'
162162
if (cb) {

0 commit comments

Comments
 (0)