()
| 839 | } |
| 840 | |
| 841 | async function PortalSuspended() { |
| 842 | try { |
| 843 | const x = await Promise.resolve(query.cursorFn(result)) |
| 844 | rows = 0 |
| 845 | x === CLOSE |
| 846 | ? write(Close(query.portal)) |
| 847 | : (result = new Result(), write(Execute('', query.cursorRows))) |
| 848 | } catch (err) { |
| 849 | write(Sync) |
| 850 | query.reject(err) |
| 851 | } |
| 852 | } |
| 853 | |
| 854 | function CloseComplete() { |
| 855 | result.count && query.cursorFn(result) |