refactor: send only once per stream

No need to do it at every row, probably entirely wrong. However this is
not the cause of the slowness reported in #286.

diff --git a/psycopg/psycopg/cursor.py b/psycopg/psycopg/cursor.py
index c613f43111b93df5acbf5e1cc3b719186adb55d3..2c127587d6e4c2ff74513f3b8347cd534d4b6623 100644 (file)
--- a/psycopg/psycopg/cursor.py
+++ b/psycopg/psycopg/cursor.py
@@ -281,9 +281,9 @@ class BaseCursor(Generic[ConnectionType, Row]):
         self._execute_send(pgq, binary=binary, no_pqexec=True)
         self._pgconn.set_single_row_mode()
         self._last_query = query
+        yield from send(self._pgconn)
 
     def _stream_fetchone_gen(self, first: bool) -> PQGen[Optional["PGresult"]]:
-        yield from send(self._pgconn)
         res = yield from fetch(self._pgconn)
         if res is None:
             return None