Called with the full rowset on subscribe and after every committed
mutation that changes it. The push is awaited before the next
iteration runs: a slow consumer gets backpressure (intervening
commits coalesce into the next rowset), and a dead one — e.g. a
disconnected RPC peer — rejects, tearing the subscription down
instead of leaking a watcher.
OptionalonReturn
onReturn?:()=>unknown
Called if the live stream ends without error (bus stopped).
Called with the full rowset on subscribe and after every committed mutation that changes it. The push is awaited before the next iteration runs: a slow consumer gets backpressure (intervening commits coalesce into the next rowset), and a dead one — e.g. a disconnected RPC peer — rejects, tearing the subscription down instead of leaking a watcher.