diff --git a/psycopg/replication_cursor_type.c b/psycopg/replication_cursor_type.c index a590386a..5fdeaf03 100644 --- a/psycopg/replication_cursor_type.c +++ b/psycopg/replication_cursor_type.c @@ -152,7 +152,7 @@ consume_stream(replicationCursorObject *self, CLEARPGRES(curs->pgres); self->consuming = 1; - if (keepalive_interval >= 1) { + if (keepalive_interval > 0) { set_status_interval(self, keepalive_interval); }