Exit current pipeline by sending a Sync and fetch back all remaining results.
(self)
| 96 | yield from self._fetch_gen(flush=False) |
| 97 | |
| 98 | def _exit_gen(self) -> PQGen[None]: |
| 99 | """ |
| 100 | Exit current pipeline by sending a Sync and fetch back all remaining results. |
| 101 | """ |
| 102 | try: |
| 103 | self._enqueue_sync() |
| 104 | yield from self._communicate_gen() |
| 105 | finally: |
| 106 | yield from self._fetch_gen(flush=True) |
| 107 | |
| 108 | def _communicate_gen(self) -> PQGen[None]: |
| 109 | """Communicate with pipeline to send commands and possibly fetch |
no test coverage detected