psycopg2: Add ReplicationCursor.consume_stream (#11283)

This commit is contained in:
fovc9
2024-01-17 18:54:36 -06:00
committed by GitHub
parent 605e9a7b99
commit 7129bd112b

View File

@@ -196,6 +196,9 @@ class ReplicationCursor(_replicationCursor):
status_interval: int = 10,
) -> None: ...
def fileno(self): ...
def consume_stream(
self, consume: Callable[[ReplicationMessage], object], keepalive_interval: float | None = None
) -> None: ...
class UUID_adapter:
def __init__(self, uuid) -> None: ...