Class LiveSubscription<Rows>

A live subscription: drives the underlying iterator and pushes each committed rowset into the observer. Construct via LiveSubscription.start (the constructor is private); iterating stops on unsubscribe() / disposal, when the stream ends, or when a push throws. Generic in Rows so the retained callbacks stay typed on the instance — Rows appears only in the private machinery, not in the public surface.