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