Runs subscribe-and-consume attempts until stopped or terminally failed.
Between attempts the engine sleeps with equal-jitter exponential backoff
(baseDelayMs doubling per consecutive failure up to maxDelayMs); the
failure counter resets after any successful attempt (see
DEFAULT_SUCCESS_INTERVAL_MS for what counts as success), so a
disconnect hours into a healthy stream resubscribes promptly.
Runs subscribe-and-consume attempts until stopped or terminally failed.
Between attempts the engine sleeps with equal-jitter exponential backoff (
baseDelayMsdoubling per consecutive failure up tomaxDelayMs); the failure counter resets after any successful attempt (see DEFAULT_SUCCESS_INTERVAL_MS for what counts as success), so a disconnect hours into a healthy stream resubscribes promptly.