(query)
| 348 | } |
| 349 | |
| 350 | function cancel(query) { |
| 351 | return new Promise((resolve, reject) => { |
| 352 | query.state |
| 353 | ? query.active |
| 354 | ? Connection(options).cancel(query.state, resolve, reject) |
| 355 | : query.cancelled = { resolve, reject } |
| 356 | : ( |
| 357 | queries.remove(query), |
| 358 | query.cancelled = true, |
| 359 | query.reject(Errors.generic('57014', 'canceling statement due to user request')), |
| 360 | resolve() |
| 361 | ) |
| 362 | }) |
| 363 | } |
| 364 | |
| 365 | async function end({ timeout = null } = {}) { |
| 366 | if (ending) |
nothing calls this directly
no test coverage detected