There was an error while loading. Please reload this page.
1 parent 9d3b1df commit ed5dbc8Copy full SHA for ed5dbc8
ext/pg_connection.c
@@ -3060,7 +3060,8 @@ pgconn_async_get_last_result(VALUE self)
3060
for(;;) {
3061
int status;
3062
3063
-pgconn_block( 0, NULL, self ); /* wait for input (without blocking) before reading the last result */
+/* wait for input (without blocking) before reading each result */
3064
+wait_socket_readable(self, NULL, get_result_readable);
3065
3066
cur = gvl_PQgetResult(conn);
3067
if (cur == NULL)
0 commit comments