(rows, cb)
| 187 | } |
| 188 | |
| 189 | _getRows(rows, cb) { |
| 190 | this.state = 'busy' |
| 191 | this._cb = cb |
| 192 | this._rows = [] |
| 193 | const msg = { |
| 194 | portal: this._portal, |
| 195 | rows: rows, |
| 196 | } |
| 197 | this.connection.execute(msg, true) |
| 198 | this.connection.flush() |
| 199 | } |
| 200 | |
| 201 | // users really shouldn't be calling 'end' here and terminating a connection to postgres |
| 202 | // via the low level connection.end api |